<!DOCTYPE html>
<html lang="zh-CN">
  <head>
    <meta charset="utf-8">
    <meta name="viewport" content="width=device-width,initial-scale=1">
    <title>SA实战 ·《SpringCloud Alibaba实战》第20章-消息服务：RocketMQ核心技术 | 冰河技术</title>
    <meta name="generator" content="VuePress 1.9.7">
    <link rel="icon" href="/favicon.ico">
    <script charset="utf-8" async="async" src="/js/jquery.min.js"></script>
    <script charset="utf-8" async="async" src="/js/global.js"></script>
    <script charset="utf-8" async="async" src="/js/fingerprint2.min.js"></script>
    <script charset="utf-8" async="async" src="https://v1.cnzz.com/z_stat.php?id=1281063564&amp;web_id=1281063564"></script>
    <script charset="utf-8" async="async" src="https://s9.cnzz.com/z_stat.php?id=1281064551&amp;web_id=1281064551"></script>
    <script>
            var _hmt = _hmt || [];
            (function() {
              var hm = document.createElement("script");
              hm.src = "https://hm.baidu.com/hm.js?d091d2fd0231588b1d0f9231e24e3f5e";
              var s = document.getElementsByTagName("script")[0];
              s.parentNode.insertBefore(hm, s);
            })();
            </script>
    <meta name="description" content="包含：编程语言，开发技术，分布式，微服务，高并发，高可用，高可扩展，高可维护，JVM技术，MySQL，分布式数据库，分布式事务，云原生，大数据，云计算，渗透技术，各种面试题，面试技巧...">
    <meta property="article:modified_time" content="2022-05-23T11:30:51.000Z">
    <meta property="og:title" content="SA实战 ·《SpringCloud Alibaba实战》第20章-消息服务：RocketMQ核心技术">
    <meta property="og:type" content="article">
    <meta property="og:url" content="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html">
    <meta name="twitter:title" content="SA实战 ·《SpringCloud Alibaba实战》第20章-消息服务：RocketMQ核心技术">
    <meta name="twitter:url" content="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html">
    <meta name="twitter:card" content="summary_large_image">
    <meta name="robots" content="all">
    <meta name="author" content="冰河">
    <meta http-equiv="Cache-Control" content="no-cache, no-store, must-revalidate">
    <meta http-equiv="Pragma" content="no-cache">
    <meta http-equiv="Expires" content="0">
    <meta name="keywords" content="冰河，冰河技术, 编程语言，开发技术，分布式，微服务，高并发，高可用，高可扩展，高可维护，JVM技术，MySQL，分布式数据库，分布式事务，云原生，大数据，云计算，渗透技术，各种面试题，面试技巧">
    <meta name="apple-mobile-web-app-capable" content="yes">
    
    <link rel="preload" href="/assets/css/0.styles.ab888ebb.css" as="style"><link rel="preload" href="/assets/css/styles.css?v=1653305936337" as="style"><link rel="preload" href="/assets/js/cg-styles.js?v=1653305936337" as="script"><link rel="preload" href="/assets/js/cg-app.js?v=1653305936337" as="script"><link rel="preload" href="/assets/js/cg-4.js?v=1653305936337" as="script"><link rel="preload" href="/assets/js/cg-3.js?v=1653305936337" as="script"><link rel="preload" href="/assets/js/cg-308.js?v=1653305936337" as="script"><link rel="preload" href="/assets/js/cg-5.js?v=1653305936337" as="script"><link rel="preload" href="/assets/js/cg-6.js?v=1653305936337" as="script">
    <link rel="stylesheet" href="/assets/css/0.styles.ab888ebb.css"><link rel="stylesheet" href="/assets/css/styles.css?v=1653305936337">
  </head>
  <body>
    <div id="app" data-server-rendered="true"><div class="theme-container"><header class="navbar"><div class="sidebar-button"><svg xmlns="http://www.w3.org/2000/svg" aria-hidden="true" role="img" viewBox="0 0 448 512" class="icon"><path fill="currentColor" d="M436 124H12c-6.627 0-12-5.373-12-12V80c0-6.627 5.373-12 12-12h424c6.627 0 12 5.373 12 12v32c0 6.627-5.373 12-12 12zm0 160H12c-6.627 0-12-5.373-12-12v-32c0-6.627 5.373-12 12-12h424c6.627 0 12 5.373 12 12v32c0 6.627-5.373 12-12 12zm0 160H12c-6.627 0-12-5.373-12-12v-32c0-6.627 5.373-12 12-12h424c6.627 0 12 5.373 12 12v32c0 6.627-5.373 12-12 12z"></path></svg></div> <a href="/" class="home-link router-link-active"><!----> <span class="site-name">冰河技术</span></a> <div class="links"><div class="search-box"><input aria-label="Search" autocomplete="off" spellcheck="false" value=""> <!----></div> <nav class="nav-links can-hide"><div class="nav-item"><a href="/md/other/guide-to-reading.html" class="nav-link">
  导读
</a></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="核心技术" class="dropdown-title"><span class="title">核心技术</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><h4>
          Java核心技术
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/core/java/basics/2022-04-28-全网最全正则表达式总结.html" class="nav-link">
  Java基础
</a></li><li class="dropdown-subitem"><a href="/md/core/java/advanced/default.html" class="nav-link">
  Java进阶
</a></li><li class="dropdown-subitem"><a href="/md/core/java/senior/default.html" class="nav-link">
  Java高级
</a></li><li class="dropdown-subitem"><a href="/md/core/java/java8/2022-03-31-001-Java8有哪些新特性呢？.html" class="nav-link">
  Java8新特性
</a></li></ul></li><li class="dropdown-item"><h4>
          Spring核心技术
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/core/spring/ioc/2022-04-04-001-聊聊Spring注解驱动开发那些事儿.html" class="nav-link">
  IOC核心技术
</a></li><li class="dropdown-subitem"><a href="/md/core/spring/aop/default.html" class="nav-link">
  AOP核心技术
</a></li></ul></li><li class="dropdown-item"><h4>
          JVM核心技术
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/core/jvm/2022-04-18-001-JVM调优的几种场景.html" class="nav-link">
  JVM调优技术
</a></li></ul></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="性能调优" class="dropdown-title"><span class="title">性能调优</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><!----> <a href="/md/performance/jvm/default.html" class="nav-link">
  JVM性能调优
</a></li><li class="dropdown-item"><!----> <a href="/md/performance/tomcat/default.html" class="nav-link">
  Tomcat性能调优
</a></li><li class="dropdown-item"><!----> <a href="/md/performance/mysql/default.html" class="nav-link">
  MySQL性能调优
</a></li><li class="dropdown-item"><!----> <a href="/md/performance/system/default.html" class="nav-link">
  操作系统性能调优
</a></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="并发编程" class="dropdown-title"><span class="title">并发编程</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><!----> <a href="/md/concurrent/bottom/default.html" class="nav-link">
  底层技术
</a></li><li class="dropdown-item"><!----> <a href="/md/concurrent/source/2020-03-30-001-一文搞懂线程与多线程.html" class="nav-link">
  源码分析
</a></li><li class="dropdown-item"><!----> <a href="/md/concurrent/basics/2020-03-30-001-明明中断了线程，却为何不起作用呢？.html" class="nav-link">
  基础案例
</a></li><li class="dropdown-item"><!----> <a href="/md/concurrent/ActualCombat/default.html" class="nav-link">
  实战案例
</a></li><li class="dropdown-item"><!----> <a href="/md/concurrent/interview/default.html" class="nav-link">
  面试
</a></li><li class="dropdown-item"><!----> <a href="/md/concurrent/framework/default.html" class="nav-link">
  系统架构
</a></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="框架源码" class="dropdown-title"><span class="title">框架源码</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><!----> <a href="/md/frame/spring/default.html" class="nav-link">
  Spring源码
</a></li><li class="dropdown-item"><!----> <a href="/md/frame/springmvc/default.html" class="nav-link">
  SpringMVC源码
</a></li><li class="dropdown-item"><!----> <a href="/md/frame/mybatis/default.html" class="nav-link">
  MyBatis源码
</a></li><li class="dropdown-item"><!----> <a href="/md/frame/dubbo/default.html" class="nav-link">
  Dubbo源码
</a></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="分布式" class="dropdown-title"><span class="title">分布式</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><h4>
          缓存技术
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/distributed/cache/default.html" class="nav-link">
  Redis
</a></li></ul></li><li class="dropdown-item"><h4>
          服务注册发现
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/distributed/zookeeper/default.html" class="nav-link">
  Zookeeper
</a></li></ul></li><li class="dropdown-item"><h4>
          消息中间件
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/distributed/mq/rabbitmq/default.html" class="nav-link">
  RabbitMQ
</a></li><li class="dropdown-subitem"><a href="/md/distributed/mq/rocketmq/default.html" class="nav-link">
  RocketMQ
</a></li><li class="dropdown-subitem"><a href="/md/distributed/mq/kafka/default.html" class="nav-link">
  Kafka
</a></li></ul></li><li class="dropdown-item"><h4>
          网络通信
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/distributed/netty/default.html" class="nav-link">
  Netty
</a></li></ul></li><li class="dropdown-item"><h4>
          远程调用
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/distributed/dubbo/default.html" class="nav-link">
  Dubbo
</a></li></ul></li><li class="dropdown-item"><h4>
          数据库
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/distributed/mongodb/default.html" class="nav-link">
  MongoDB
</a></li></ul></li><li class="dropdown-item"><h4>
          搜索引擎
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/distributed/es/default.html" class="nav-link">
  ElasticSearch
</a></li></ul></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="微服务" class="dropdown-title"><span class="title">微服务</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><!----> <a href="/md/microservices/springboot/default.html" class="nav-link">
  SpringBoot
</a></li><li class="dropdown-item"><!----> <a href="/md/microservices/springcloudalibaba/2022-04-02-SpringCloudAlibaba专栏开篇.html" class="nav-link">
  SpringCloudAlibaba
</a></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="中间件" class="dropdown-title"><span class="title">中间件</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><!----> <a href="/md/middleware/bytecode/2022-04-11-001-工作多年的你依然重复做着CRUD-是否接触过这种技术.html" class="nav-link">
  字节码编程
</a></li><li class="dropdown-item"><!----> <a href="/md/middleware/threadpool/default.html" class="nav-link">
  手写线程池
</a></li><li class="dropdown-item"><!----> <a href="/md/middleware/limiter/default.html" class="nav-link">
  分布式限流
</a></li><li class="dropdown-item"><!----> <a href="/md/middleware/independent/default.html" class="nav-link">
  开源项目
</a></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="项目实战" class="dropdown-title"><span class="title">项目实战</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><!----> <a href="/md/microservices/springcloudalibaba/2022-04-02-SpringCloudAlibaba专栏开篇.html" class="nav-link">
  SpringCloud Alibaba实战
</a></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="渗透技术" class="dropdown-title"><span class="title">渗透技术</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><!----> <a href="/md/hack/environment/2022-04-17-001-安装Kali系统.html" class="nav-link">
  基础环境篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/tools/2022-04-17-001-使用Easy-Creds工具攻击无线网络.html" class="nav-link">
  渗透工具篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/horse/2022-05-02-001-各种一句话木马大全.html" class="nav-link">
  木马篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/sql/2022-05-02-001-sqli-labs-master下载与安装.html" class="nav-link">
  SQL注入篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/shell/2022-05-02-001-各种解析漏洞拿shell.html" class="nav-link">
  漏洞拿Shell篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/crack/2022-05-02-001-使用rarcrack暴力破解RAR-ZIP-7Z压缩包.html" class="nav-link">
  暴力破解篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/bash/2022-05-02-001-3389脚本开启代码(vbs版).html" class="nav-link">
  渗透脚本篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/raising/2022-05-02-001-数据库提权.html" class="nav-link">
  数据与系统提权篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/client/2022-05-02-001-浏览器渗透.html" class="nav-link">
  客户端渗透篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/sociology/2022-05-02-001-Metasploit之社会工程学工具包.html" class="nav-link">
  社会工程学
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/question/2022-05-02-001-HTTP错误4031禁止访问-执行访问被拒绝.html" class="nav-link">
  问题记录篇
</a></li></ul></div></div><div class="nav-item"><a href="/md/interview/2022-04-18-001-面试必问-聊聊JVM性能调优.html" class="nav-link">
  面试必问系列
</a></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="📚PDF" class="dropdown-title"><span class="title">📚PDF</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><h4>
          出版图书
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/knowledge/book/2022-03-29-深入理解分布式事务.html" class="nav-link">
  《深入理解分布式事务：原理与实战》
</a></li><li class="dropdown-subitem"><a href="/md/knowledge/book/2022-03-29-MySQL技术大全.html" class="nav-link">
  《MySQL技术大全：开发、优化与运维实战》
</a></li><li class="dropdown-subitem"><a href="/md/knowledge/book/2022-03-29-海量数据处理与大数据技术实战.html" class="nav-link">
  《海量数据处理与大数据技术实战》
</a></li></ul></li><li class="dropdown-item"><h4>
          电子书籍
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/knowledge/pdf/2022-03-30-《冰河的渗透实战笔记》电子书，442页，37万字，正式发布.html" class="nav-link">
  冰河的渗透实战笔记
</a></li></ul></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="关于" class="dropdown-title"><span class="title">关于</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><!----> <a href="/md/about/me/about-me.html" class="nav-link">
  关于自己
</a></li><li class="dropdown-item"><!----> <a href="/md/about/study/default.html" class="nav-link">
  关于学习
</a></li><li class="dropdown-item"><!----> <a href="/md/about/job/default.html" class="nav-link">
  关于职场
</a></li></ul></div></div><div class="nav-item"><a href="https://space.bilibili.com/517638832" target="_blank" rel="noopener noreferrer" class="nav-link external">
  B站
  <span><svg xmlns="http://www.w3.org/2000/svg" aria-hidden="true" focusable="false" x="0px" y="0px" viewBox="0 0 100 100" width="15" height="15" class="icon outbound"><path fill="currentColor" d="M18.8,85.1h56l0,0c2.2,0,4-1.8,4-4v-32h-8v28h-48v-48h28v-8h-32l0,0c-2.2,0-4,1.8-4,4v56C14.8,83.3,16.6,85.1,18.8,85.1z"></path> <polygon fill="currentColor" points="45.7,48.7 51.3,54.3 77.2,28.5 77.2,37.2 85.2,37.2 85.2,14.9 62.8,14.9 62.8,22.9 71.5,22.9"></polygon></svg> <span class="sr-only">(opens new window)</span></span></a></div><div class="nav-item"><a href="https://github.com/binghe001/BingheGuide" target="_blank" rel="noopener noreferrer" class="nav-link external">
  Github
  <span><svg xmlns="http://www.w3.org/2000/svg" aria-hidden="true" focusable="false" x="0px" y="0px" viewBox="0 0 100 100" width="15" height="15" class="icon outbound"><path fill="currentColor" d="M18.8,85.1h56l0,0c2.2,0,4-1.8,4-4v-32h-8v28h-48v-48h28v-8h-32l0,0c-2.2,0-4,1.8-4,4v56C14.8,83.3,16.6,85.1,18.8,85.1z"></path> <polygon fill="currentColor" points="45.7,48.7 51.3,54.3 77.2,28.5 77.2,37.2 85.2,37.2 85.2,14.9 62.8,14.9 62.8,22.9 71.5,22.9"></polygon></svg> <span class="sr-only">(opens new window)</span></span></a></div> <!----></nav></div></header> <div class="sidebar-mask"></div> <aside class="sidebar"><nav class="nav-links"><div class="nav-item"><a href="/md/other/guide-to-reading.html" class="nav-link">
  导读
</a></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="核心技术" class="dropdown-title"><span class="title">核心技术</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><h4>
          Java核心技术
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/core/java/basics/2022-04-28-全网最全正则表达式总结.html" class="nav-link">
  Java基础
</a></li><li class="dropdown-subitem"><a href="/md/core/java/advanced/default.html" class="nav-link">
  Java进阶
</a></li><li class="dropdown-subitem"><a href="/md/core/java/senior/default.html" class="nav-link">
  Java高级
</a></li><li class="dropdown-subitem"><a href="/md/core/java/java8/2022-03-31-001-Java8有哪些新特性呢？.html" class="nav-link">
  Java8新特性
</a></li></ul></li><li class="dropdown-item"><h4>
          Spring核心技术
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/core/spring/ioc/2022-04-04-001-聊聊Spring注解驱动开发那些事儿.html" class="nav-link">
  IOC核心技术
</a></li><li class="dropdown-subitem"><a href="/md/core/spring/aop/default.html" class="nav-link">
  AOP核心技术
</a></li></ul></li><li class="dropdown-item"><h4>
          JVM核心技术
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/core/jvm/2022-04-18-001-JVM调优的几种场景.html" class="nav-link">
  JVM调优技术
</a></li></ul></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="性能调优" class="dropdown-title"><span class="title">性能调优</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><!----> <a href="/md/performance/jvm/default.html" class="nav-link">
  JVM性能调优
</a></li><li class="dropdown-item"><!----> <a href="/md/performance/tomcat/default.html" class="nav-link">
  Tomcat性能调优
</a></li><li class="dropdown-item"><!----> <a href="/md/performance/mysql/default.html" class="nav-link">
  MySQL性能调优
</a></li><li class="dropdown-item"><!----> <a href="/md/performance/system/default.html" class="nav-link">
  操作系统性能调优
</a></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="并发编程" class="dropdown-title"><span class="title">并发编程</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><!----> <a href="/md/concurrent/bottom/default.html" class="nav-link">
  底层技术
</a></li><li class="dropdown-item"><!----> <a href="/md/concurrent/source/2020-03-30-001-一文搞懂线程与多线程.html" class="nav-link">
  源码分析
</a></li><li class="dropdown-item"><!----> <a href="/md/concurrent/basics/2020-03-30-001-明明中断了线程，却为何不起作用呢？.html" class="nav-link">
  基础案例
</a></li><li class="dropdown-item"><!----> <a href="/md/concurrent/ActualCombat/default.html" class="nav-link">
  实战案例
</a></li><li class="dropdown-item"><!----> <a href="/md/concurrent/interview/default.html" class="nav-link">
  面试
</a></li><li class="dropdown-item"><!----> <a href="/md/concurrent/framework/default.html" class="nav-link">
  系统架构
</a></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="框架源码" class="dropdown-title"><span class="title">框架源码</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><!----> <a href="/md/frame/spring/default.html" class="nav-link">
  Spring源码
</a></li><li class="dropdown-item"><!----> <a href="/md/frame/springmvc/default.html" class="nav-link">
  SpringMVC源码
</a></li><li class="dropdown-item"><!----> <a href="/md/frame/mybatis/default.html" class="nav-link">
  MyBatis源码
</a></li><li class="dropdown-item"><!----> <a href="/md/frame/dubbo/default.html" class="nav-link">
  Dubbo源码
</a></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="分布式" class="dropdown-title"><span class="title">分布式</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><h4>
          缓存技术
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/distributed/cache/default.html" class="nav-link">
  Redis
</a></li></ul></li><li class="dropdown-item"><h4>
          服务注册发现
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/distributed/zookeeper/default.html" class="nav-link">
  Zookeeper
</a></li></ul></li><li class="dropdown-item"><h4>
          消息中间件
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/distributed/mq/rabbitmq/default.html" class="nav-link">
  RabbitMQ
</a></li><li class="dropdown-subitem"><a href="/md/distributed/mq/rocketmq/default.html" class="nav-link">
  RocketMQ
</a></li><li class="dropdown-subitem"><a href="/md/distributed/mq/kafka/default.html" class="nav-link">
  Kafka
</a></li></ul></li><li class="dropdown-item"><h4>
          网络通信
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/distributed/netty/default.html" class="nav-link">
  Netty
</a></li></ul></li><li class="dropdown-item"><h4>
          远程调用
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/distributed/dubbo/default.html" class="nav-link">
  Dubbo
</a></li></ul></li><li class="dropdown-item"><h4>
          数据库
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/distributed/mongodb/default.html" class="nav-link">
  MongoDB
</a></li></ul></li><li class="dropdown-item"><h4>
          搜索引擎
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/distributed/es/default.html" class="nav-link">
  ElasticSearch
</a></li></ul></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="微服务" class="dropdown-title"><span class="title">微服务</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><!----> <a href="/md/microservices/springboot/default.html" class="nav-link">
  SpringBoot
</a></li><li class="dropdown-item"><!----> <a href="/md/microservices/springcloudalibaba/2022-04-02-SpringCloudAlibaba专栏开篇.html" class="nav-link">
  SpringCloudAlibaba
</a></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="中间件" class="dropdown-title"><span class="title">中间件</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><!----> <a href="/md/middleware/bytecode/2022-04-11-001-工作多年的你依然重复做着CRUD-是否接触过这种技术.html" class="nav-link">
  字节码编程
</a></li><li class="dropdown-item"><!----> <a href="/md/middleware/threadpool/default.html" class="nav-link">
  手写线程池
</a></li><li class="dropdown-item"><!----> <a href="/md/middleware/limiter/default.html" class="nav-link">
  分布式限流
</a></li><li class="dropdown-item"><!----> <a href="/md/middleware/independent/default.html" class="nav-link">
  开源项目
</a></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="项目实战" class="dropdown-title"><span class="title">项目实战</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><!----> <a href="/md/microservices/springcloudalibaba/2022-04-02-SpringCloudAlibaba专栏开篇.html" class="nav-link">
  SpringCloud Alibaba实战
</a></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="渗透技术" class="dropdown-title"><span class="title">渗透技术</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><!----> <a href="/md/hack/environment/2022-04-17-001-安装Kali系统.html" class="nav-link">
  基础环境篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/tools/2022-04-17-001-使用Easy-Creds工具攻击无线网络.html" class="nav-link">
  渗透工具篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/horse/2022-05-02-001-各种一句话木马大全.html" class="nav-link">
  木马篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/sql/2022-05-02-001-sqli-labs-master下载与安装.html" class="nav-link">
  SQL注入篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/shell/2022-05-02-001-各种解析漏洞拿shell.html" class="nav-link">
  漏洞拿Shell篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/crack/2022-05-02-001-使用rarcrack暴力破解RAR-ZIP-7Z压缩包.html" class="nav-link">
  暴力破解篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/bash/2022-05-02-001-3389脚本开启代码(vbs版).html" class="nav-link">
  渗透脚本篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/raising/2022-05-02-001-数据库提权.html" class="nav-link">
  数据与系统提权篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/client/2022-05-02-001-浏览器渗透.html" class="nav-link">
  客户端渗透篇
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/sociology/2022-05-02-001-Metasploit之社会工程学工具包.html" class="nav-link">
  社会工程学
</a></li><li class="dropdown-item"><!----> <a href="/md/hack/question/2022-05-02-001-HTTP错误4031禁止访问-执行访问被拒绝.html" class="nav-link">
  问题记录篇
</a></li></ul></div></div><div class="nav-item"><a href="/md/interview/2022-04-18-001-面试必问-聊聊JVM性能调优.html" class="nav-link">
  面试必问系列
</a></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="📚PDF" class="dropdown-title"><span class="title">📚PDF</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><h4>
          出版图书
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/knowledge/book/2022-03-29-深入理解分布式事务.html" class="nav-link">
  《深入理解分布式事务：原理与实战》
</a></li><li class="dropdown-subitem"><a href="/md/knowledge/book/2022-03-29-MySQL技术大全.html" class="nav-link">
  《MySQL技术大全：开发、优化与运维实战》
</a></li><li class="dropdown-subitem"><a href="/md/knowledge/book/2022-03-29-海量数据处理与大数据技术实战.html" class="nav-link">
  《海量数据处理与大数据技术实战》
</a></li></ul></li><li class="dropdown-item"><h4>
          电子书籍
        </h4> <ul class="dropdown-subitem-wrapper"><li class="dropdown-subitem"><a href="/md/knowledge/pdf/2022-03-30-《冰河的渗透实战笔记》电子书，442页，37万字，正式发布.html" class="nav-link">
  冰河的渗透实战笔记
</a></li></ul></li></ul></div></div><div class="nav-item"><div class="dropdown-wrapper"><button type="button" aria-label="关于" class="dropdown-title"><span class="title">关于</span> <span class="arrow right"></span></button> <ul class="nav-dropdown" style="display:none;"><li class="dropdown-item"><!----> <a href="/md/about/me/about-me.html" class="nav-link">
  关于自己
</a></li><li class="dropdown-item"><!----> <a href="/md/about/study/default.html" class="nav-link">
  关于学习
</a></li><li class="dropdown-item"><!----> <a href="/md/about/job/default.html" class="nav-link">
  关于职场
</a></li></ul></div></div><div class="nav-item"><a href="https://space.bilibili.com/517638832" target="_blank" rel="noopener noreferrer" class="nav-link external">
  B站
  <span><svg xmlns="http://www.w3.org/2000/svg" aria-hidden="true" focusable="false" x="0px" y="0px" viewBox="0 0 100 100" width="15" height="15" class="icon outbound"><path fill="currentColor" d="M18.8,85.1h56l0,0c2.2,0,4-1.8,4-4v-32h-8v28h-48v-48h28v-8h-32l0,0c-2.2,0-4,1.8-4,4v56C14.8,83.3,16.6,85.1,18.8,85.1z"></path> <polygon fill="currentColor" points="45.7,48.7 51.3,54.3 77.2,28.5 77.2,37.2 85.2,37.2 85.2,14.9 62.8,14.9 62.8,22.9 71.5,22.9"></polygon></svg> <span class="sr-only">(opens new window)</span></span></a></div><div class="nav-item"><a href="https://github.com/binghe001/BingheGuide" target="_blank" rel="noopener noreferrer" class="nav-link external">
  Github
  <span><svg xmlns="http://www.w3.org/2000/svg" aria-hidden="true" focusable="false" x="0px" y="0px" viewBox="0 0 100 100" width="15" height="15" class="icon outbound"><path fill="currentColor" d="M18.8,85.1h56l0,0c2.2,0,4-1.8,4-4v-32h-8v28h-48v-48h28v-8h-32l0,0c-2.2,0-4,1.8-4,4v56C14.8,83.3,16.6,85.1,18.8,85.1z"></path> <polygon fill="currentColor" points="45.7,48.7 51.3,54.3 77.2,28.5 77.2,37.2 85.2,37.2 85.2,14.9 62.8,14.9 62.8,22.9 71.5,22.9"></polygon></svg> <span class="sr-only">(opens new window)</span></span></a></div> <!----></nav>  <ul class="sidebar-links"><li><section class="sidebar-group depth-0"><p class="sidebar-heading"><span>SpringBoot</span> <!----></p> <ul class="sidebar-links sidebar-group-items"><li><a href="/md/microservices/springboot/default.html" class="sidebar-link">关于我</a></li></ul></section></li><li><section class="sidebar-group depth-0"><p class="sidebar-heading open"><span>SpringCloudAlibaba</span> <!----></p> <ul class="sidebar-links sidebar-group-items"><li><a href="/md/microservices/springcloudalibaba/2022-04-02-SpringCloudAlibaba专栏开篇.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》专栏开篇啦</a></li><li><a href="/md/microservices/springcloudalibaba/2022-04-04-SA实战·第一篇-专栏设计.html" class="sidebar-link">SA实战 · 《SpringCloud Alibaba实战》专栏设计</a></li><li><a href="/md/microservices/springcloudalibaba/2022-04-09-SA实战-微服务介绍.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》微服务介绍</a></li><li><a href="/md/microservices/springcloudalibaba/2022-04-13-SA实战·项目说明-流程设计-技术选型-模块划分.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》项目说明、流程设计、技术选型与模块划分</a></li><li><a href="/md/microservices/springcloudalibaba/2022-04-18-SA实战-开撸-完成通用模块的开发.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》开撸：完成通用模块的开发</a></li><li><a href="/md/microservices/springcloudalibaba/2022-04-21-SA实战-完成三大微服务的搭建与交互开发.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》快速搭建三大微服务并完成交互开发与测试</a></li><li><a href="/md/microservices/springcloudalibaba/2022-04-25-SA实战-服务治理-实现服务的注册与发现.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》服务治理：实现服务的自动注册与发现</a></li><li><a href="/md/microservices/springcloudalibaba/2022-04-27-SA实战-第8章-服务治理-实现服务调用的负载均衡.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》第8章-服务治理：实现服务调用的负载均衡</a></li><li><a href="/md/microservices/springcloudalibaba/2022-04-28-SA实战-第9章-服务容错-服务雪崩与容错方案.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》第9章-服务容错：服务雪崩与容错方案</a></li><li><a href="/md/microservices/springcloudalibaba/2022-05-03-SA实战-第10章-服务容错-Fegin整合Sentinel.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》第10章-服务容错：项目整合Sentinel实现限流与容错</a></li><li><a href="/md/microservices/springcloudalibaba/2022-05-05-SA实战-第11章-服务容错加餐-Sentinel核心技术与配置规则.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》第11章-服务容错加餐：Sentinel核心技术与配置规则（最全使用教程）</a></li><li><a href="/md/microservices/springcloudalibaba/2022-05-08-SA实战-第12章-服务网关-网关概述与核心架构.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》第12章-服务网关：网关概述与核心架构</a></li><li><a href="/md/microservices/springcloudalibaba/2022-05-08-SA实战-第13章-服务网关-项目整合SpringCloudGateway.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》第13章-服务网关：项目整合SpringCloud Gateway网关</a></li><li><a href="/md/microservices/springcloudalibaba/2022-05-10-SA实战-第14章-服务网关-SpringCloudGateway核心技术.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》第14章-服务网关加餐：SpringCloud Gateway核心技术</a></li><li><a href="/md/microservices/springcloudalibaba/2022-05-11-SA实战-第15章-链路追踪-核心原理与解决方案.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》第15章-链路追踪：核心原理与解决方案</a></li><li><a href="/md/microservices/springcloudalibaba/2022-05-12-SA实战-第16章-链路追踪-项目整合Sleuth实现链路追踪.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》第16章-链路追踪：项目整合Sleuth实现链路追踪</a></li><li><a href="/md/microservices/springcloudalibaba/2022-05-13-SA实战-第17章-链路追踪-Sleuth整合ZipKin.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》第17章-链路追踪：Sleuth整合ZipKin</a></li><li><a href="/md/microservices/springcloudalibaba/2022-05-17-SA实战-第18章-消息服务-MQ使用场景与选型对比.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》第18章-消息服务：MQ使用场景与选型对比</a></li><li><a href="/md/microservices/springcloudalibaba/2022-05-18-SA实战-第19章-消息服务-项目整合RocketMQ.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》第19章-消息服务：项目整合RocketMQ</a></li><li><a href="/md/microservices/springcloudalibaba/2022-05-20-SA实战-第20章-消息服务-RocketMQ核心技术.html" class="active sidebar-link">SA实战 ·《SpringCloud Alibaba实战》第20章-消息服务：RocketMQ核心技术</a></li><li><a href="/md/microservices/springcloudalibaba/2022-05-21-SA实战-第21章-服务配置-服务配置介绍与Nacos核心概念.html" class="sidebar-link">SA实战 ·《SpringCloud Alibaba实战》第21章-服务配置：服务配置介绍与Nacos核心概念</a></li></ul></section></li></ul> </aside> <div><main class="page"> <div class="theme-default-content content__default"><h1 id="sa实战-·《springcloud-alibaba实战》第20章-消息服务-rocketmq核心技术"><a href="#sa实战-·《springcloud-alibaba实战》第20章-消息服务-rocketmq核心技术" class="header-anchor">#</a> SA实战 ·《SpringCloud Alibaba实战》第20章-消息服务：RocketMQ核心技术</h1> <p><strong>大家好，我是冰河~~</strong></p> <blockquote><p>一不小心《<a href="https://mp.weixin.qq.com/mp/appmsgalbum?__biz=Mzg4MjU0OTM1OA==&amp;action=getalbum&amp;album_id=2337104419664084992&amp;scene=173&amp;from_msgid=2247500408&amp;from_itemidx=1&amp;count=3&amp;nolastread=1#wechat_redirect" target="_blank" rel="noopener noreferrer">SpringCloud Alibaba实战<span><svg xmlns="http://www.w3.org/2000/svg" aria-hidden="true" focusable="false" x="0px" y="0px" viewBox="0 0 100 100" width="15" height="15" class="icon outbound"><path fill="currentColor" d="M18.8,85.1h56l0,0c2.2,0,4-1.8,4-4v-32h-8v28h-48v-48h28v-8h-32l0,0c-2.2,0-4,1.8-4,4v56C14.8,83.3,16.6,85.1,18.8,85.1z"></path> <polygon fill="currentColor" points="45.7,48.7 51.3,54.3 77.2,28.5 77.2,37.2 85.2,37.2 85.2,14.9 62.8,14.9 62.8,22.9 71.5,22.9"></polygon></svg> <span class="sr-only">(opens new window)</span></span></a>》专栏都更新到第20章了，再不上车就跟不上了，小伙伴们快跟上啊！</p> <p>注意：本项目完整源码加入 <strong><a href="https://public.zsxq.com/groups/48848484411888.html" target="_blank" rel="noopener noreferrer">冰河技术<span><svg xmlns="http://www.w3.org/2000/svg" aria-hidden="true" focusable="false" x="0px" y="0px" viewBox="0 0 100 100" width="15" height="15" class="icon outbound"><path fill="currentColor" d="M18.8,85.1h56l0,0c2.2,0,4-1.8,4-4v-32h-8v28h-48v-48h28v-8h-32l0,0c-2.2,0-4,1.8-4,4v56C14.8,83.3,16.6,85.1,18.8,85.1z"></path> <polygon fill="currentColor" points="45.7,48.7 51.3,54.3 77.2,28.5 77.2,37.2 85.2,37.2 85.2,14.9 62.8,14.9 62.8,22.9 71.5,22.9"></polygon></svg> <span class="sr-only">(opens new window)</span></span></a></strong> 知识星球即可获取，文末有入场方式。</p> <p>本文大部分内容来源：https://github.com/apache/rocketmq/tree/master/docs/cn</p></blockquote> <p>在《<a href="https://mp.weixin.qq.com/mp/appmsgalbum?__biz=Mzg4MjU0OTM1OA==&amp;action=getalbum&amp;album_id=2337104419664084992&amp;scene=173&amp;from_msgid=2247500408&amp;from_itemidx=1&amp;count=3&amp;nolastread=1#wechat_redirect" target="_blank" rel="noopener noreferrer">SpringCloud Alibaba实战<span><svg xmlns="http://www.w3.org/2000/svg" aria-hidden="true" focusable="false" x="0px" y="0px" viewBox="0 0 100 100" width="15" height="15" class="icon outbound"><path fill="currentColor" d="M18.8,85.1h56l0,0c2.2,0,4-1.8,4-4v-32h-8v28h-48v-48h28v-8h-32l0,0c-2.2,0-4,1.8-4,4v56C14.8,83.3,16.6,85.1,18.8,85.1z"></path> <polygon fill="currentColor" points="45.7,48.7 51.3,54.3 77.2,28.5 77.2,37.2 85.2,37.2 85.2,14.9 62.8,14.9 62.8,22.9 71.5,22.9"></polygon></svg> <span class="sr-only">(opens new window)</span></span></a>》专栏前面的文章中，我们实现了用户微服务、商品微服务和订单微服务之间的远程调用，并且实现了服务调用的负载均衡。也基于阿里开源的Sentinel实现了服务的限流与容错，并详细介绍了Sentinel的核心技术与配置规则。简单介绍了服务网关，并对SpringCloud Gateway的核心架构进行了简要说明，也在项目中整合了SpringCloud Gateway网关实现了通过网关访问后端微服务.</p> <p>同时，也基于SpringCloud Gateway整合Sentinel实现了网关的限流功能，详细介绍了SpringCloud Gateway网关的核心技术。在链路追踪章节，我们开始简单介绍了分布式链路追踪技术与解决方案，随后在项目中整合Sleuth实现了链路追踪，并使用Sleuth整合ZipKin实现了分布式链路追踪的可视化 。</p> <p>在消息服务章节，我们介绍了MQ的使用场景，引入MQ后的注意事项以及MQ的选型对比，在项目中整合了RocketMQ。接下来，再给大家介绍下RocketMQ的核心技术。</p> <h2 id="本章总览"><a href="#本章总览" class="header-anchor">#</a> 本章总览</h2> <p><img alt="sa-2022-05-20-010" data-src="https://binghe001.github.io/assets/images/microservices/springcloudalibaba/sa-2022-05-20-010.png" loading="lazy" class="lazy"></p> <h2 id="idea启动rocketmq源码"><a href="#idea启动rocketmq源码" class="header-anchor">#</a> IDEA启动RocketMQ源码</h2> <p>RocketMQ是使用Java语言开发的，我们可以将RocketMQ的源码导入到IDEA中，使用IDEA来导入并启动RocketMQ的源码，接下来就可以在IDEA中调试RocketMQ的源码。</p> <h3 id="下载rocketmq源码"><a href="#下载rocketmq源码" class="header-anchor">#</a> 下载RocketMQ源码</h3> <p>到链接<a href="https://github.com/apache/rocketmq/releases/tag/rocketmq-all-4.9.3" target="_blank" rel="noopener noreferrer">https://github.com/apache/rocketmq/releases/tag/rocketmq-all-4.9.3<span><svg xmlns="http://www.w3.org/2000/svg" aria-hidden="true" focusable="false" x="0px" y="0px" viewBox="0 0 100 100" width="15" height="15" class="icon outbound"><path fill="currentColor" d="M18.8,85.1h56l0,0c2.2,0,4-1.8,4-4v-32h-8v28h-48v-48h28v-8h-32l0,0c-2.2,0-4,1.8-4,4v56C14.8,83.3,16.6,85.1,18.8,85.1z"></path> <polygon fill="currentColor" points="45.7,48.7 51.3,54.3 77.2,28.5 77.2,37.2 85.2,37.2 85.2,14.9 62.8,14.9 62.8,22.9 71.5,22.9"></polygon></svg> <span class="sr-only">(opens new window)</span></span></a>下载RocketMQ源码，这里下载的是RocketMQ 4.9.3版本。</p> <h3 id="将源码导入idea"><a href="#将源码导入idea" class="header-anchor">#</a> 将源码导入IDEA</h3> <p>将RocketMQ下载的本地后，就可以将RocketMQ的源码导入到IDEA中了。导入后的项目结构如下所示。</p> <p><img alt="sa-2022-05-20-001" data-src="https://binghe001.github.io/assets/images/microservices/springcloudalibaba/sa-2022-05-20-001.png" loading="lazy" class="lazy"></p> <h3 id="编译rocketmq源码"><a href="#编译rocketmq源码" class="header-anchor">#</a> 编译RocketMQ源码</h3> <p>在IDEA编译RocketMQ源码，需要在IDEA中配置Maven编译，如下所示。</p> <p><img alt="sa-2022-05-20-002" data-src="https://binghe001.github.io/assets/images/microservices/springcloudalibaba/sa-2022-05-20-002.png" loading="lazy" class="lazy"></p> <p>如图所示，需要输入名称、在Working directory对应的地方选择要使用Maven编译的项目目录，这里，选择RocketMQ项目的根目录，表示编译整个RocketMQ项目。在Command line对应的文本框中输入<code>clean install -Dmaven.test.skip=true</code>来编译RocketMQ源码。其中<code>-Dmaven.test.skip=true</code>参数表示在编译的过程中忽略测试。</p> <p>配置好之后点击IDEA右上角的运行按钮开始编译RocketMQ的源码，如下所示。</p> <p><img alt="sa-2022-05-20-003" data-src="https://binghe001.github.io/assets/images/microservices/springcloudalibaba/sa-2022-05-20-003.png" loading="lazy" class="lazy"></p> <p>在编译的过程中可能会下载一些RocketMQ源码依赖的Jar包和插件，等待一会即可。</p> <h3 id="启动rocketmq"><a href="#启动rocketmq" class="header-anchor">#</a> 启动RocketMQ</h3> <p>在IDEA中启动RocketMQ的源码需要进行简单的配置，具体的步骤如下所示。</p> <p>（1）在RocketMQ源码的根目录下创建conf目录，并将distribution模块下的conf目录的broker.conf文件、logback_namesrv.xml文件和logback_broker.xml文件复制到RocketMQ源码的根目录下创建conf目录中，如下所示。</p> <p><img alt="sa-2022-05-20-004" data-src="https://binghe001.github.io/assets/images/microservices/springcloudalibaba/sa-2022-05-20-004.png" loading="lazy" class="lazy"></p> <p>（2）文件复制完成后，修改broker.conf文件的内容，修改后的内容如下所示。</p> <div class="language-bash line-numbers-mode"><pre class="language-bash"><code>brokerClusterName <span class="token operator">=</span> DefaultCluster
brokerName <span class="token operator">=</span> broker-a
brokerId <span class="token operator">=</span> <span class="token number">0</span>
deleteWhen <span class="token operator">=</span> 04
fileReservedTime <span class="token operator">=</span> <span class="token number">48</span>
brokerRole <span class="token operator">=</span> ASYNC_MASTER
flushDiskType <span class="token operator">=</span> ASYNC_FLUSH

<span class="token comment"># 自动创建Topic</span>
<span class="token assign-left variable">autoCreateTopicEnable</span><span class="token operator">=</span>true
<span class="token comment"># nameServ地址</span>
<span class="token assign-left variable">namesrvAddr</span><span class="token operator">=</span><span class="token number">127.0</span>.0.1:9876
<span class="token comment"># 存储路径</span>
<span class="token assign-left variable">storePathRootDir</span><span class="token operator">=</span>E:/RocketMQ/data/rocketmq/dataDir
<span class="token comment"># commitLog路径</span>
<span class="token assign-left variable">storePathCommitLog</span><span class="token operator">=</span>E:/RocketMQ/data/rocketmq/dataDir/commitlog
<span class="token comment"># 消息队列存储路径</span>
<span class="token assign-left variable">storePathConsumeQueue</span><span class="token operator">=</span>E:/RocketMQ/data/rocketmq/dataDir/consumequeue
<span class="token comment"># 消息索引存储路径</span>
<span class="token assign-left variable">storePathIndex</span><span class="token operator">=</span>E:/RocketMQ/data/rocketmq/dataDir/index
<span class="token comment"># checkpoint文件路径</span>
<span class="token assign-left variable">storeCheckpoint</span><span class="token operator">=</span>E:/RocketMQ/data/rocketmq/dataDir/checkpoint
<span class="token comment"># abort文件存储路径</span>
<span class="token assign-left variable">abortFile</span><span class="token operator">=</span>E:/RocketMQ/data/rocketmq/dataDir/abort
</code></pre> <div class="line-numbers-wrapper"><span class="line-number">1</span><br><span class="line-number">2</span><br><span class="line-number">3</span><br><span class="line-number">4</span><br><span class="line-number">5</span><br><span class="line-number">6</span><br><span class="line-number">7</span><br><span class="line-number">8</span><br><span class="line-number">9</span><br><span class="line-number">10</span><br><span class="line-number">11</span><br><span class="line-number">12</span><br><span class="line-number">13</span><br><span class="line-number">14</span><br><span class="line-number">15</span><br><span class="line-number">16</span><br><span class="line-number">17</span><br><span class="line-number">18</span><br><span class="line-number">19</span><br><span class="line-number">20</span><br><span class="line-number">21</span><br><span class="line-number">22</span><br><span class="line-number">23</span><br><span class="line-number">24</span><br></div></div><p>（3）配置NameServer启动项，NameServer的启动类，在RocketMQ源码的namesrv模块中，如下所示。</p> <p><img alt="sa-2022-05-20-005" data-src="https://binghe001.github.io/assets/images/microservices/springcloudalibaba/sa-2022-05-20-005.png" loading="lazy" class="lazy"></p> <p>启动前先要在IDEA中配置下NameServer的启动类，如下所示。</p> <p><img alt="sa-2022-05-20-006" data-src="https://binghe001.github.io/assets/images/microservices/springcloudalibaba/sa-2022-05-20-006.png" loading="lazy" class="lazy"></p> <p>启动NameServer前重点是要在IDEA的Environment variables中配置ROCKETMQ_HOME环境变量，这里，ROCKETMQ_HOME环境变量的值是RocketMQ源码的根目录。</p> <p>（4）配置Broker启动项，Broker的启动类，在RocketMQ源码中的broker模块中，如下所示。</p> <p><img alt="sa-2022-05-20-007" data-src="https://binghe001.github.io/assets/images/microservices/springcloudalibaba/sa-2022-05-20-007.png" loading="lazy" class="lazy"></p> <p>启动前先要在IDEA中配置下Broker的启动类，如下所示。</p> <p><img alt="sa-2022-05-20-008" data-src="https://binghe001.github.io/assets/images/microservices/springcloudalibaba/sa-2022-05-20-008.png" loading="lazy" class="lazy"></p> <p>配置Broker的启动类时，除了要在Environment variables后面配置ROCKETMQ_HOME环境变量外，还要在Program arguments后面配置启动RocketMQ时加载的配置文件，这里的配置文件使用-c参数指向RocketMQ源码根目录下的conf目录中的broker.conf文件，如下所示。</p> <div class="language-bash line-numbers-mode"><pre class="language-bash"><code>-c D:<span class="token punctuation">\</span>Workspaces<span class="token punctuation">\</span>myself<span class="token punctuation">\</span>rocketmq<span class="token punctuation">\</span>src<span class="token punctuation">\</span>rocketmq-rocketmq-all-4.9.3<span class="token punctuation">\</span>conf<span class="token punctuation">\</span>broker.conf
</code></pre> <div class="line-numbers-wrapper"><span class="line-number">1</span><br></div></div><p>（5）在IDEA中分别启动RocketMQ的NameServer和Broker，可以发现在启动NameServer的控制台输出了如下日志信息。</p> <div class="language-bash line-numbers-mode"><pre class="language-bash"><code>The Name Server boot success. <span class="token assign-left variable">serializeType</span><span class="token operator">=</span>JSON
</code></pre> <div class="line-numbers-wrapper"><span class="line-number">1</span><br></div></div><p>在启动Broker的控制台输出了如下日志信息。</p> <div class="language-bash line-numbers-mode"><pre class="language-bash"><code>The broker<span class="token punctuation">[</span>broker-a, <span class="token number">192.168</span>.184.1:10911<span class="token punctuation">]</span> boot success. <span class="token assign-left variable">serializeType</span><span class="token operator">=</span>JSON and name server is <span class="token number">127.0</span>.0.1:9876
</code></pre> <div class="line-numbers-wrapper"><span class="line-number">1</span><br></div></div><p>此时，我们到在broker.conf文件中配置的RocketMQ存储数据的根目录<code>E:/RocketMQ/data/rocketmq/dataDir</code>下查看具体信息，如下所示。</p> <p><img alt="sa-2022-05-20-009" data-src="https://binghe001.github.io/assets/images/microservices/springcloudalibaba/sa-2022-05-20-009.png" loading="lazy" class="lazy"></p> <p>可以看到，在<code>E:/RocketMQ/data/rocketmq/dataDir</code>目录下生成了RocketMQ相关的存储信息。</p> <p>综上，我们成功在IDEA中导入并启动了RocketMQ的源码。接下来，小伙伴们就可以在IDEA中随心所欲的调试RocketMQ的源码了。</p> <h2 id="rocketmq基本概念"><a href="#rocketmq基本概念" class="header-anchor">#</a> RocketMQ基本概念</h2> <h3 id="消息模型"><a href="#消息模型" class="header-anchor">#</a> 消息模型</h3> <p>RocketMQ主要由 Producer、Broker、Consumer 三部分组成，其中Producer 负责生产消息，Consumer 负责消费消息，Broker 负责存储消息。Broker 在实际部署过程中对应一台服务器，每个 Broker 可以存储多个Topic的消息，每个Topic的消息也可以分片存储于不同的 Broker。Message Queue 用于存储消息的物理地址，每个Topic中的消息地址存储于多个 Message Queue 中。ConsumerGroup 由多个Consumer 实例构成。</p> <h3 id="消息生产者"><a href="#消息生产者" class="header-anchor">#</a> 消息生产者</h3> <p>负责生产消息，一般由业务系统负责生产消息。一个消息生产者会把业务应用系统里产生的消息发送到broker服务器。RocketMQ提供多种发送方式，同步发送、异步发送、顺序发送、单向发送。同步和异步方式均需要Broker返回确认信息，单向发送不需要。</p> <h3 id="消息消费者"><a href="#消息消费者" class="header-anchor">#</a> 消息消费者</h3> <p>负责消费消息，一般是后台系统负责异步消费。一个消息消费者会从Broker服务器拉取消息、并将其提供给应用程序。从用户应用的角度而言提供了两种消费形式：拉取式消费、推动式消费。</p> <h3 id="主题"><a href="#主题" class="header-anchor">#</a> 主题</h3> <p>表示一类消息的集合，每个主题包含若干条消息，每条消息只能属于一个主题，是RocketMQ进行消息订阅的基本单位。</p> <h3 id="代理服务器"><a href="#代理服务器" class="header-anchor">#</a> 代理服务器</h3> <p>消息中转角色，负责存储消息、转发消息。代理服务器在RocketMQ系统中负责接收从生产者发送来的消息并存储、同时为消费者的拉取请求作准备。代理服务器也存储消息相关的元数据，包括消费者组、消费进度偏移和主题和队列消息等。</p> <h3 id="名字服务"><a href="#名字服务" class="header-anchor">#</a> 名字服务</h3> <p>名称服务充当路由消息的提供者。生产者或消费者能够通过名字服务查找各主题相应的Broker IP列表。多个Namesrv实例组成集群，但相互独立，没有信息交换。</p> <h3 id="拉取式消费"><a href="#拉取式消费" class="header-anchor">#</a> 拉取式消费</h3> <p>Consumer消费的一种类型，应用通常主动调用Consumer的拉消息方法从Broker服务器拉消息、主动权由应用控制。一旦获取了批量消息，应用就会启动消费过程。</p> <h3 id="推动式消费"><a href="#推动式消费" class="header-anchor">#</a> 推动式消费</h3> <p>Consumer消费的一种类型，该模式下Broker收到数据后会主动推送给消费端，该消费模式一般实时性较高。</p> <h3 id="生产者组"><a href="#生产者组" class="header-anchor">#</a> 生产者组</h3> <p>同一类Producer的集合，这类Producer发送同一类消息且发送逻辑一致。如果发送的是事务消息且原始生产者在发送之后崩溃，则Broker服务器会联系同一生产者组的其他生产者实例以提交或回溯消费。</p> <h3 id="消费者组"><a href="#消费者组" class="header-anchor">#</a> 消费者组</h3> <p>同一类Consumer的集合，这类Consumer通常消费同一类消息且消费逻辑一致。消费者组使得在消息消费方面，实现负载均衡和容错的目标变得非常容易。要注意的是，消费者组的消费者实例必须订阅完全相同的Topic。RocketMQ 支持两种消息模式：集群消费（Clustering）和广播消费（Broadcasting）。</p> <h3 id="集群消费"><a href="#集群消费" class="header-anchor">#</a> 集群消费</h3> <p>集群消费模式下,相同Consumer Group的每个Consumer实例平均分摊消息。</p> <h3 id="广播消费"><a href="#广播消费" class="header-anchor">#</a> 广播消费</h3> <p>广播消费模式下，相同Consumer Group的每个Consumer实例都接收全量的消息。</p> <h3 id="普通顺序消息"><a href="#普通顺序消息" class="header-anchor">#</a> 普通顺序消息</h3> <p>普通顺序消费模式下，消费者通过同一个消息队列（ Topic 分区，称作 Message Queue） 收到的消息是有顺序的，不同消息队列收到的消息则可能是无顺序的。</p> <h3 id="严格顺序消息"><a href="#严格顺序消息" class="header-anchor">#</a> 严格顺序消息</h3> <p>严格顺序消息模式下，消费者收到的所有消息均是有顺序的。</p> <h3 id="消息"><a href="#消息" class="header-anchor">#</a> 消息</h3> <p>消息系统所传输信息的物理载体，生产和消费数据的最小单位，每条消息必须属于一个主题。RocketMQ中每个消息拥有唯一的Message ID，且可以携带具有业务标识的Key。系统提供了通过Message ID和Key查询消息的功能。</p> <h3 id="标签"><a href="#标签" class="header-anchor">#</a> 标签</h3> <p>为消息设置的标志，用于同一主题下区分不同类型的消息。来自同一业务单元的消息，可以根据不同业务目的在同一主题下设置不同标签。标签能够有效地保持代码的清晰度和连贯性，并优化RocketMQ提供的查询系统。消费者可以根据Tag实现对不同子主题的不同消费逻辑，实现更好的扩展性。</p> <h2 id="rocketmq特性"><a href="#rocketmq特性" class="header-anchor">#</a> RocketMQ特性</h2> <h3 id="订阅与发布"><a href="#订阅与发布" class="header-anchor">#</a> 订阅与发布</h3> <p>消息的发布是指某个生产者向某个topic发送消息；消息的订阅是指某个消费者关注了某个topic中带有某些tag的消息，进而从该topic消费数据。</p> <h3 id="消息顺序"><a href="#消息顺序" class="header-anchor">#</a> 消息顺序</h3> <p>消息有序指的是一类消息消费时，能按照发送的顺序来消费。例如：一个订单产生了三条消息分别是订单创建、订单付款、订单完成。消费时要按照这个顺序消费才能有意义，但是同时订单之间是可以并行消费的。RocketMQ可以严格的保证消息有序。</p> <p>顺序消息分为全局顺序消息与分区顺序消息，全局顺序是指某个Topic下的所有消息都要保证顺序；部分顺序消息只要保证每一组消息被顺序消费即可。</p> <ul><li>全局顺序
对于指定的一个 Topic，所有消息按照严格的先入先出（FIFO）的顺序进行发布和消费。
适用场景：性能要求不高，所有的消息严格按照 FIFO 原则进行消息发布和消费的场景</li> <li>分区顺序
对于指定的一个 Topic，所有消息根据 sharding key 进行区块分区。 同一个分区内的消息按照严格的 FIFO 顺序进行发布和消费。 Sharding key 是顺序消息中用来区分不同分区的关键字段，和普通消息的 Key 是完全不同的概念。
适用场景：性能要求高，以 sharding key 作为分区字段，在同一个区块中严格的按照 FIFO 原则进行消息发布和消费的场景。</li></ul> <h3 id="消息过滤"><a href="#消息过滤" class="header-anchor">#</a> 消息过滤</h3> <p>RocketMQ的消费者可以根据Tag进行消息过滤，也支持自定义属性过滤。消息过滤目前是在Broker端实现的，优点是减少了对于Consumer无用消息的网络传输，缺点是增加了Broker的负担、而且实现相对复杂。</p> <h3 id="消息可靠性"><a href="#消息可靠性" class="header-anchor">#</a> 消息可靠性</h3> <p>RocketMQ支持消息的高可靠，影响消息可靠性的几种情况：</p> <ol><li>Broker非正常关闭</li> <li>Broker异常Crash</li> <li>OS Crash</li> <li>机器掉电，但是能立即恢复供电情况</li> <li>机器无法开机（可能是cpu、主板、内存等关键设备损坏）</li> <li>磁盘设备损坏</li></ol> <p>1)、2)、3)、4) 四种情况都属于硬件资源可立即恢复情况，RocketMQ在这四种情况下能保证消息不丢，或者丢失少量数据（依赖刷盘方式是同步还是异步）。</p> <p>5)、6)属于单点故障，且无法恢复，一旦发生，在此单点上的消息全部丢失。RocketMQ在这两种情况下，通过异步复制，可保证99%的消息不丢，但是仍然会有极少量的消息可能丢失。通过同步双写技术可以完全避免单点，同步双写势必会影响性能，适合对消息可靠性要求极高的场合，例如与Money相关的应用。注：RocketMQ从3.0版本开始支持同步双写。</p> <h3 id="至少一次"><a href="#至少一次" class="header-anchor">#</a> 至少一次</h3> <p>至少一次(At least Once)指每个消息必须投递一次。Consumer先Pull消息到本地，消费完成后，才向服务器返回ack，如果没有消费一定不会ack消息，所以RocketMQ可以很好的支持此特性。</p> <h3 id="回溯消费"><a href="#回溯消费" class="header-anchor">#</a> 回溯消费</h3> <p>回溯消费是指Consumer已经消费成功的消息，由于业务上需求需要重新消费，要支持此功能，Broker在向Consumer投递成功消息后，消息仍然需要保留。并且重新消费一般是按照时间维度，例如由于Consumer系统故障，恢复后需要重新消费1小时前的数据，那么Broker要提供一种机制，可以按照时间维度来回退消费进度。RocketMQ支持按照时间回溯消费，时间维度精确到毫秒。</p> <h3 id="事务消息"><a href="#事务消息" class="header-anchor">#</a> 事务消息</h3> <p>RocketMQ事务消息（Transactional Message）是指应用本地事务和发送消息操作可以被定义到全局事务中，要么同时成功，要么同时失败。RocketMQ的事务消息提供类似 X/Open XA 的分布事务功能，通过事务消息能达到分布式事务的最终一致。</p> <h3 id="定时消息"><a href="#定时消息" class="header-anchor">#</a> 定时消息</h3> <p>定时消息（延迟队列）是指消息发送到broker后，不会立即被消费，等待特定时间投递给真正的topic。
broker有配置项messageDelayLevel，默认值为“1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h”，18个level。可以配置自定义messageDelayLevel。注意，messageDelayLevel是broker的属性，不属于某个topic。发消息时，设置delayLevel等级即可：msg.setDelayLevel(level)。level有以下三种情况：</p> <ul><li>level == 0，消息为非延迟消息</li> <li>1&lt;=level&lt;=maxLevel，消息延迟特定时间，例如level==1，延迟1s</li> <li>level &gt; maxLevel，则level== maxLevel，例如level==20，延迟2h</li></ul> <p>定时消息会暂存在名为SCHEDULE_TOPIC_XXXX的topic中，并根据delayTimeLevel存入特定的queue，queueId = delayTimeLevel – 1，即一个queue只存相同延迟的消息，保证具有相同发送延迟的消息能够顺序消费。broker会调度地消费SCHEDULE_TOPIC_XXXX，将消息写入真实的topic。</p> <p>需要注意的是，定时消息会在第一次写入和调度写入真实topic时都会计数，因此发送数量、tps都会变高。</p> <h3 id="消息重试"><a href="#消息重试" class="header-anchor">#</a> 消息重试</h3> <p>Consumer消费消息失败后，要提供一种重试机制，令消息再消费一次。Consumer消费消息失败通常可以认为有以下几种情况：</p> <ul><li>由于消息本身的原因，例如反序列化失败，消息数据本身无法处理（例如话费充值，当前消息的手机号被注销，无法充值）等。这种错误通常需要跳过这条消息，再消费其它消息，而这条失败的消息即使立刻重试消费，99%也不成功，所以最好提供一种定时重试机制，即过10秒后再重试。</li> <li>由于依赖的下游应用服务不可用，例如db连接不可用，外系统网络不可达等。遇到这种错误，即使跳过当前失败的消息，消费其他消息同样也会报错。这种情况建议应用sleep 30s，再消费下一条消息，这样可以减轻Broker重试消息的压力。</li></ul> <p>RocketMQ会为每个消费组都设置一个Topic名称为“%RETRY%+consumerGroup”的重试队列（这里需要注意的是，这个Topic的重试队列是针对消费组，而不是针对每个Topic设置的），用于暂时保存因为各种异常而导致Consumer端无法消费的消息。</p> <p>考虑到异常恢复起来需要一些时间，会为重试队列设置多个重试级别，每个重试级别都有与之对应的重新投递延时，重试次数越多投递延时就越大。RocketMQ对于重试消息的处理是先保存至Topic名称为“SCHEDULE_TOPIC_XXXX”的延迟队列中，后台定时任务按照对应的时间进行Delay后重新保存至“%RETRY%+consumerGroup”的重试队列中。</p> <h3 id="消息重投"><a href="#消息重投" class="header-anchor">#</a> 消息重投</h3> <p>生产者在发送消息时，同步消息失败会重投，异步消息有重试，oneway没有任何保证。消息重投保证消息尽可能发送成功、不丢失，但可能会造成消息重复，消息重复在RocketMQ中是无法避免的问题。消息重复在一般情况下不会发生，当出现消息量大、网络抖动，消息重复就会是大概率事件。另外，生产者主动重发、consumer负载变化也会导致重复消息。如下方法可以设置消息重试策略：</p> <ul><li>retryTimesWhenSendFailed:同步发送失败重投次数，默认为2，因此生产者会最多尝试发送retryTimesWhenSendFailed + 1次。不会选择上次失败的broker，尝试向其他broker发送，最大程度保证消息不丢。超过重投次数，抛出异常，由客户端保证消息不丢。当出现RemotingException、MQClientException和部分MQBrokerException时会重投。</li> <li>retryTimesWhenSendAsyncFailed:异步发送失败重试次数，异步重试不会选择其他broker，仅在同一个broker上做重试，不保证消息不丢。</li> <li>retryAnotherBrokerWhenNotStoreOK:消息刷盘（主或备）超时或slave不可用（返回状态非SEND_OK），是否尝试发送到其他broker，默认false。十分重要消息可以开启。</li></ul> <h3 id="流量控制"><a href="#流量控制" class="header-anchor">#</a> 流量控制</h3> <p>生产者流控，因为broker处理能力达到瓶颈；消费者流控，因为消费能力达到瓶颈。</p> <p>生产者流控：</p> <ul><li>commitLog文件被锁时间超过osPageCacheBusyTimeOutMills时，参数默认为1000ms，返回流控。</li> <li>如果开启transientStorePoolEnable == true，且broker为异步刷盘的主机，且transientStorePool中资源不足，拒绝当前send请求，返回流控。</li> <li>broker每隔10ms检查send请求队列头部请求的等待时间，如果超过waitTimeMillsInSendQueue，默认200ms，拒绝当前send请求，返回流控。</li> <li>broker通过拒绝send 请求方式实现流量控制。</li></ul> <p>注意，生产者流控，不会尝试消息重投。</p> <p>消费者流控：</p> <ul><li>消费者本地缓存消息数超过pullThresholdForQueue时，默认1000。</li> <li>消费者本地缓存消息大小超过pullThresholdSizeForQueue时，默认100MB。</li> <li>消费者本地缓存消息跨度超过consumeConcurrentlyMaxSpan时，默认2000。</li></ul> <p>消费者流控的结果是降低拉取频率。</p> <h3 id="死信队列"><a href="#死信队列" class="header-anchor">#</a> 死信队列</h3> <p>死信队列用于处理无法被正常消费的消息。当一条消息初次消费失败，消息队列会自动进行消息重试；达到最大重试次数后，若消费依然失败，则表明消费者在正常情况下无法正确地消费该消息，此时，消息队列 不会立刻将消息丢弃，而是将其发送到该消费者对应的特殊队列中。</p> <p>RocketMQ将这种正常情况下无法被消费的消息称为死信消息（Dead-Letter Message），将存储死信消息的特殊队列称为死信队列（Dead-Letter Queue）。在RocketMQ中，可以通过使用console控制台对死信队列中的消息进行重发来使得消费者实例再次进行消费。</p> <h2 id="rocketmq最佳实践"><a href="#rocketmq最佳实践" class="header-anchor">#</a> RocketMQ最佳实践</h2> <h3 id="生产者"><a href="#生产者" class="header-anchor">#</a> 生产者</h3> <h4 id="发送消息注意事项"><a href="#发送消息注意事项" class="header-anchor">#</a> 发送消息注意事项</h4> <p><strong>Tags的使用</strong></p> <p>一个应用尽可能用一个Topic，而消息子类型则可以用tags来标识。tags可以由应用自由设置，只有生产者在发送消息设置了tags，消费方在订阅消息时才可以利用tags通过broker做消息过滤：message.setTags(&quot;TagA&quot;)。</p> <p><strong>Keys的使用</strong></p> <p>每个消息在业务层面的唯一标识码要设置到keys字段，方便将来定位消息丢失问题。服务器会为每个消息创建索引（哈希索引），应用可以通过topic、key来查询这条消息内容，以及消息被谁消费。由于是哈希索引，请务必保证key尽可能唯一，这样可以避免潜在的哈希冲突。</p> <div class="language-java line-numbers-mode"><pre class="language-java"><code><span class="token comment">// 订单Id   </span>
<span class="token class-name">String</span> orderId <span class="token operator">=</span> <span class="token string">&quot;20034568923546&quot;</span><span class="token punctuation">;</span>   
message<span class="token punctuation">.</span><span class="token function">setKeys</span><span class="token punctuation">(</span>orderId<span class="token punctuation">)</span><span class="token punctuation">;</span>   
</code></pre> <div class="line-numbers-wrapper"><span class="line-number">1</span><br><span class="line-number">2</span><br><span class="line-number">3</span><br></div></div><p><strong>日志的打印</strong></p> <p>消息发送成功或者失败要打印消息日志，务必要打印SendResult和key字段。send消息方法只要不抛异常，就代表发送成功。发送成功会有多个状态，在sendResult里定义。以下对每个状态进行说明：</p> <ul><li><strong>SEND_OK</strong></li></ul> <p>消息发送成功。要注意的是消息发送成功也不意味着它是可靠的。要确保不会丢失任何消息，还应启用同步Master服务器或同步刷盘，即SYNC_MASTER或SYNC_FLUSH。</p> <ul><li><strong>FLUSH_DISK_TIMEOUT</strong></li></ul> <p>消息发送成功但是服务器刷盘超时。此时消息已经进入服务器队列（内存），只有服务器宕机，消息才会丢失。消息存储配置参数中可以设置刷盘方式和同步刷盘时间长度，如果Broker服务器设置了刷盘方式为同步刷盘，即FlushDiskType=SYNC_FLUSH（默认为异步刷盘方式），当Broker服务器未在同步刷盘时间内（默认为5s）完成刷盘，则将返回该状态——刷盘超时。</p> <ul><li><strong>FLUSH_SLAVE_TIMEOUT</strong></li></ul> <p>消息发送成功，但是服务器同步到Slave时超时。此时消息已经进入服务器队列，只有服务器宕机，消息才会丢失。如果Broker服务器的角色是同步Master，即SYNC_MASTER（默认是异步Master即ASYNC_MASTER），并且从Broker服务器未在同步刷盘时间（默认为5秒）内完成与主服务器的同步，则将返回该状态——数据同步到Slave服务器超时。</p> <ul><li><strong>SLAVE_NOT_AVAILABLE</strong></li></ul> <p>消息发送成功，但是此时Slave不可用。如果Broker服务器的角色是同步Master，即SYNC_MASTER（默认是异步Master服务器即ASYNC_MASTER），但没有配置slave Broker服务器，则将返回该状态——无Slave服务器可用。</p> <h4 id="消息发送失败处理方式"><a href="#消息发送失败处理方式" class="header-anchor">#</a> 消息发送失败处理方式</h4> <p>Producer的send方法本身支持内部重试，重试逻辑如下：</p> <ul><li>至多重试2次。</li> <li>如果同步模式发送失败，则轮转到下一个Broker，如果异步模式发送失败，则只会在当前Broker进行重试。这个方法的总耗时时间不超过sendMsgTimeout设置的值，默认10s。</li> <li>如果本身向broker发送消息产生超时异常，就不会再重试。</li></ul> <p>以上策略也是在一定程度上保证了消息可以发送成功。如果业务对消息可靠性要求比较高，建议应用增加相应的重试逻辑：比如调用send同步方法发送失败时，则尝试将消息存储到db，然后由后台线程定时重试，确保消息一定到达Broker。</p> <p>上述db重试方式为什么没有集成到MQ客户端内部做，而是要求应用自己去完成，主要基于以下几点考虑：首先，MQ的客户端设计为无状态模式，方便任意的水平扩展，且对机器资源的消耗仅仅是cpu、内存、网络。其次，如果MQ客户端内部集成一个KV存储模块，那么数据只有同步落盘才能较可靠，而同步落盘本身性能开销较大，所以通常会采用异步落盘，又由于应用关闭过程不受MQ运维人员控制，可能经常会发生 kill -9 这样暴力方式关闭，造成数据没有及时落盘而丢失。第三，Producer所在机器的可靠性较低，一般为虚拟机，不适合存储重要数据。综上，建议重试过程交由应用来控制。</p> <h4 id="选择oneway形式发送"><a href="#选择oneway形式发送" class="header-anchor">#</a> 选择oneway形式发送</h4> <p>通常消息的发送是这样一个过程：</p> <ul><li>客户端发送请求到服务器</li> <li>服务器处理请求</li> <li>服务器向客户端返回应答</li></ul> <p>所以，一次消息发送的耗时时间是上述三个步骤的总和，而某些场景要求耗时非常短，但是对可靠性要求并不高，例如日志收集类应用，此类应用可以采用oneway形式调用，oneway形式只发送请求不等待应答，而发送请求在客户端实现层面仅仅是一个操作系统系统调用的开销，即将数据写入客户端的socket缓冲区，此过程耗时通常在微秒级。</p> <h3 id="消费者"><a href="#消费者" class="header-anchor">#</a> 消费者</h3> <h4 id="消费过程幂等"><a href="#消费过程幂等" class="header-anchor">#</a> 消费过程幂等</h4> <p>RocketMQ无法避免消息重复（Exactly-Once），所以如果业务对消费重复非常敏感，务必要在业务层面进行去重处理。可以借助关系数据库进行去重。首先需要确定消息的唯一键，可以是msgId，也可以是消息内容中的唯一标识字段，例如订单Id等。在消费之前判断唯一键是否在关系数据库中存在。如果不存在则插入，并消费，否则跳过。（实际过程要考虑原子性问题，判断是否存在可以尝试插入，如果报主键冲突，则插入失败，直接跳过）</p> <p>msgId一定是全局唯一标识符，但是实际使用中，可能会存在相同的消息有两个不同msgId的情况（消费者主动重发、因客户端重投机制导致的重复等），这种情况就需要使业务字段进行重复消费。</p> <h4 id="消费速度慢的处理方式"><a href="#消费速度慢的处理方式" class="header-anchor">#</a> 消费速度慢的处理方式</h4> <p><strong>提高消费并行度</strong></p> <p>绝大部分消息消费行为都属于 IO 密集型，即可能是操作数据库，或者调用 RPC，这类消费行为的消费速度在于后端数据库或者外系统的吞吐量，通过增加消费并行度，可以提高总的消费吞吐量，但是并行度增加到一定程度，反而会下降。所以，应用必须要设置合理的并行度。 如下有几种修改消费并行度的方法：</p> <ul><li>同一个 ConsumerGroup 下，通过增加 Consumer 实例数量来提高并行度（需要注意的是超过订阅队列数的 Consumer 实例无效）。可以通过加机器，或者在已有机器启动多个进程的方式。</li> <li>提高单个 Consumer 的消费并行线程，通过修改参数 consumeThreadMin、consumeThreadMax实现。</li></ul> <p><strong>批量方式消费</strong></p> <p>某些业务流程如果支持批量方式消费，则可以很大程度上提高消费吞吐量，例如订单扣款类应用，一次处理一个订单耗时 1 s，一次处理 10 个订单可能也只耗时 2 s，这样即可大幅度提高消费的吞吐量，通过设置 consumer的 consumeMessageBatchMaxSize 返个参数，默认是 1，即一次只消费一条消息，例如设置为 N，那么每次消费的消息数小于等于 N。</p> <p><strong>跳过非重要消息</strong></p> <p>发生消息堆积时，如果消费速度一直追不上发送速度，如果业务对数据要求不高的话，可以选择丢弃不重要的消息。例如，当某个队列的消息数堆积到100000条以上，则尝试丢弃部分或全部消息，这样就可以快速追上发送消息的速度。示例代码如下：</p> <div class="language-java line-numbers-mode"><pre class="language-java"><code><span class="token keyword">public</span> <span class="token class-name">ConsumeConcurrentlyStatus</span> <span class="token function">consumeMessage</span><span class="token punctuation">(</span>
    <span class="token class-name">List</span><span class="token generics"><span class="token punctuation">&lt;</span><span class="token class-name">MessageExt</span><span class="token punctuation">&gt;</span></span> msgs<span class="token punctuation">,</span>
    <span class="token class-name">ConsumeConcurrentlyContext</span> context<span class="token punctuation">)</span> <span class="token punctuation">{</span>
    <span class="token keyword">long</span> offset <span class="token operator">=</span> msgs<span class="token punctuation">.</span><span class="token function">get</span><span class="token punctuation">(</span><span class="token number">0</span><span class="token punctuation">)</span><span class="token punctuation">.</span><span class="token function">getQueueOffset</span><span class="token punctuation">(</span><span class="token punctuation">)</span><span class="token punctuation">;</span>
    <span class="token class-name">String</span> maxOffset <span class="token operator">=</span>
        msgs<span class="token punctuation">.</span><span class="token function">get</span><span class="token punctuation">(</span><span class="token number">0</span><span class="token punctuation">)</span><span class="token punctuation">.</span><span class="token function">getProperty</span><span class="token punctuation">(</span><span class="token class-name">Message</span><span class="token punctuation">.</span>PROPERTY_MAX_OFFSET<span class="token punctuation">)</span><span class="token punctuation">;</span>
    <span class="token keyword">long</span> diff <span class="token operator">=</span> <span class="token class-name">Long</span><span class="token punctuation">.</span><span class="token function">parseLong</span><span class="token punctuation">(</span>maxOffset<span class="token punctuation">)</span> <span class="token operator">-</span> offset<span class="token punctuation">;</span>
    <span class="token keyword">if</span> <span class="token punctuation">(</span>diff <span class="token operator">&gt;</span> <span class="token number">100000</span><span class="token punctuation">)</span> <span class="token punctuation">{</span>
        <span class="token comment">// TODO 消息堆积情况的特殊处理</span>
        <span class="token keyword">return</span> <span class="token class-name">ConsumeConcurrentlyStatus</span><span class="token punctuation">.</span>CONSUME_SUCCESS<span class="token punctuation">;</span>
    <span class="token punctuation">}</span>
    <span class="token comment">// TODO 正常消费过程</span>
    <span class="token keyword">return</span> <span class="token class-name">ConsumeConcurrentlyStatus</span><span class="token punctuation">.</span>CONSUME_SUCCESS<span class="token punctuation">;</span>
<span class="token punctuation">}</span>    
</code></pre> <div class="line-numbers-wrapper"><span class="line-number">1</span><br><span class="line-number">2</span><br><span class="line-number">3</span><br><span class="line-number">4</span><br><span class="line-number">5</span><br><span class="line-number">6</span><br><span class="line-number">7</span><br><span class="line-number">8</span><br><span class="line-number">9</span><br><span class="line-number">10</span><br><span class="line-number">11</span><br><span class="line-number">12</span><br><span class="line-number">13</span><br><span class="line-number">14</span><br></div></div><p><strong>优化每条消息消费过程</strong></p> <p>举例如下，某条消息的消费过程如下：</p> <ul><li>根据消息从 DB 查询【数据 1】</li> <li>根据消息从 DB 查询【数据 2】</li> <li>复杂的业务计算</li> <li>向 DB 插入【数据 3】</li> <li>向 DB 插入【数据 4】</li></ul> <p>这条消息的消费过程中有4次与 DB的 交互，如果按照每次 5ms 计算，那么总共耗时 20ms，假设业务计算耗时 5ms，那么总过耗时 25ms，所以如果能把 4 次 DB 交互优化为 2 次，那么总耗时就可以优化到 15ms，即总体性能提高了 40%。所以应用如果对时延敏感的话，可以把DB部署在SSD硬盘，相比于SCSI磁盘，前者的RT会小很多。</p> <h4 id="消费打印日志"><a href="#消费打印日志" class="header-anchor">#</a> 消费打印日志</h4> <p>如果消息量较少，建议在消费入口方法打印消息，消费耗时等，方便后续排查问题。</p> <div class="language-java line-numbers-mode"><pre class="language-java"><code><span class="token keyword">public</span> <span class="token class-name">ConsumeConcurrentlyStatus</span> <span class="token function">consumeMessage</span><span class="token punctuation">(</span>
    <span class="token class-name">List</span><span class="token generics"><span class="token punctuation">&lt;</span><span class="token class-name">MessageExt</span><span class="token punctuation">&gt;</span></span> msgs<span class="token punctuation">,</span>
    <span class="token class-name">ConsumeConcurrentlyContext</span> context<span class="token punctuation">)</span> <span class="token punctuation">{</span>
    log<span class="token punctuation">.</span><span class="token function">info</span><span class="token punctuation">(</span><span class="token string">&quot;RECEIVE_MSG_BEGIN: &quot;</span> <span class="token operator">+</span> msgs<span class="token punctuation">.</span><span class="token function">toString</span><span class="token punctuation">(</span><span class="token punctuation">)</span><span class="token punctuation">)</span><span class="token punctuation">;</span>
    <span class="token comment">// TODO 正常消费过程</span>
    <span class="token keyword">return</span> <span class="token class-name">ConsumeConcurrentlyStatus</span><span class="token punctuation">.</span>CONSUME_SUCCESS<span class="token punctuation">;</span>
<span class="token punctuation">}</span>   
</code></pre> <div class="line-numbers-wrapper"><span class="line-number">1</span><br><span class="line-number">2</span><br><span class="line-number">3</span><br><span class="line-number">4</span><br><span class="line-number">5</span><br><span class="line-number">6</span><br><span class="line-number">7</span><br></div></div><p>如果能打印每条消息消费耗时，那么在排查消费慢等线上问题时，会更方便。</p> <h4 id="其他消费建议"><a href="#其他消费建议" class="header-anchor">#</a> 其他消费建议</h4> <p><strong>关于消费者和订阅</strong></p> <p>第一件需要注意的事情是，不同的消费者组可以独立的消费一些 topic，并且每个消费者组都有自己的消费偏移量，请确保同一组内的每个消费者订阅信息保持一致。</p> <p><strong>关于有序消息</strong></p> <p>消费者将锁定每个消息队列，以确保他们被逐个消费，虽然这将会导致性能下降，但是当你关心消息顺序的时候会很有用。我们不建议抛出异常，你可以返回 ConsumeOrderlyStatus.SUSPEND_CURRENT_QUEUE_A_MOMENT 作为替代。</p> <p><strong>关于并发消费</strong></p> <p>顾名思义，消费者将并发消费这些消息，建议你使用它来获得良好性能，我们不建议抛出异常，你可以返回 ConsumeConcurrentlyStatus.RECONSUME_LATER 作为替代。</p> <p><strong>关于消费状态Consume Status</strong></p> <p>对于并发的消费监听器，你可以返回 RECONSUME_LATER 来通知消费者现在不能消费这条消息，并且希望可以稍后重新消费它。然后，你可以继续消费其他消息。对于有序的消息监听器，因为你关心它的顺序，所以不能跳过消息，但是你可以返回SUSPEND_CURRENT_QUEUE_A_MOMENT 告诉消费者等待片刻。</p> <p><strong>关于Blocking</strong></p> <p>不建议阻塞监听器，因为它会阻塞线程池，并最终可能会终止消费进程</p> <p><strong>关于线程数设置</strong></p> <p>消费者使用 ThreadPoolExecutor 在内部对消息进行消费，所以你可以通过设置 setConsumeThreadMin 或 setConsumeThreadMax 来改变它。</p> <p><strong>关于消费位点</strong></p> <p>当建立一个新的消费者组时，需要决定是否需要消费已经存在于 Broker 中的历史消息CONSUME_FROM_LAST_OFFSET 将会忽略历史消息，并消费之后生成的任何消息。CONSUME_FROM_FIRST_OFFSET 将会消费每个存在于 Broker 中的信息。你也可以使用 CONSUME_FROM_TIMESTAMP 来消费在指定时间戳后产生的消息。</p> <h3 id="broker"><a href="#broker" class="header-anchor">#</a> Broker</h3> <h4 id="broker-角色"><a href="#broker-角色" class="header-anchor">#</a> Broker 角色</h4> <p>Broker 角色分为 ASYNC_MASTER（异步主机）、SYNC_MASTER（同步主机）以及SLAVE（从机）。如果对消息的可靠性要求比较严格，可以采用 SYNC_MASTER加SLAVE的部署方式。如果对消息可靠性要求不高，可以采用ASYNC_MASTER加SLAVE的部署方式。如果只是测试方便，则可以选择仅ASYNC_MASTER或仅SYNC_MASTER的部署方式。</p> <h4 id="flushdisktype"><a href="#flushdisktype" class="header-anchor">#</a> FlushDiskType</h4> <p>SYNC_FLUSH（同步刷新）相比于ASYNC_FLUSH（异步处理）会损失很多性能，但是也更可靠，所以需要根据实际的业务场景做好权衡。</p> <h4 id="broker-配置"><a href="#broker-配置" class="header-anchor">#</a> Broker 配置</h4> <table><thead><tr><th>参数名</th> <th>默认值</th> <th>说明</th></tr></thead> <tbody><tr><td>listenPort</td> <td>10911</td> <td>接受客户端连接的监听端口</td></tr> <tr><td>namesrvAddr</td> <td>null</td> <td>nameServer 地址</td></tr> <tr><td>brokerIP1</td> <td>网卡的 InetAddress</td> <td>当前 broker 监听的 IP</td></tr> <tr><td>brokerIP2</td> <td>跟 brokerIP1 一样</td> <td>存在主从 broker 时，如果在 broker 主节点上配置了 brokerIP2 属性，broker 从节点会连接主节点配置的 brokerIP2 进行同步</td></tr> <tr><td>brokerName</td> <td>null</td> <td>broker 的名称</td></tr> <tr><td>brokerClusterName</td> <td>DefaultCluster</td> <td>本 broker 所属的 Cluser 名称</td></tr> <tr><td>brokerId</td> <td>0</td> <td>broker id, 0 表示 master, 其他的正整数表示 slave</td></tr> <tr><td>storePathRootDir</td> <td>$HOME/store/</td> <td>存储根路径</td></tr> <tr><td>storePathCommitLog</td> <td>$HOME/store/commitlog/</td> <td>存储 commit log 的路径</td></tr> <tr><td>mappedFileSizeCommitLog</td> <td>1024 * 1024 * 1024(1G)</td> <td>commit log 的映射文件大小</td></tr> <tr><td>deleteWhen</td> <td>04</td> <td>在每天的什么时间删除已经超过文件保留时间的 commit log</td></tr> <tr><td>fileReservedTime</td> <td>72</td> <td>以小时计算的文件保留时间</td></tr> <tr><td>brokerRole</td> <td>ASYNC_MASTER</td> <td>SYNC_MASTER/ASYNC_MASTER/SLAVE</td></tr> <tr><td>flushDiskType</td> <td>ASYNC_FLUSH</td> <td>SYNC_FLUSH/ASYNC_FLUSH SYNC_FLUSH 模式下的 broker 保证在收到确认生产者之前将消息刷盘。ASYNC_FLUSH 模式下的 broker 则利用刷盘一组消息的模式，可以取得更好的性能。</td></tr></tbody></table> <h3 id="nameserver"><a href="#nameserver" class="header-anchor">#</a> NameServer</h3> <p>RocketMQ 中，Name Servers 被设计用来做简单的路由管理。其职责包括：</p> <ul><li>Brokers 定期向每个名称服务器注册路由数据。</li> <li>名称服务器为客户端，包括生产者，消费者和命令行客户端提供最新的路由信息。</li></ul> <h3 id="客户端配置"><a href="#客户端配置" class="header-anchor">#</a> 客户端配置</h3> <p>相对于RocketMQ的Broker集群，生产者和消费者都是客户端。本小节主要描述生产者和消费者公共的行为配置。</p> <h4 id="客户端寻址方式"><a href="#客户端寻址方式" class="header-anchor">#</a> 客户端寻址方式</h4> <p>RocketMQ可以令客户端找到Name Server, 然后通过Name Server再找到Broker。如下所示有多种配置方式，优先级由高到低，高优先级会覆盖低优先级。</p> <ul><li>代码中指定Name Server地址，多个namesrv地址之间用分号分割</li></ul> <div class="language-java line-numbers-mode"><pre class="language-java"><code>producer<span class="token punctuation">.</span><span class="token function">setNamesrvAddr</span><span class="token punctuation">(</span><span class="token string">&quot;192.168.0.1:9876;192.168.0.2:9876&quot;</span><span class="token punctuation">)</span><span class="token punctuation">;</span>  
consumer<span class="token punctuation">.</span><span class="token function">setNamesrvAddr</span><span class="token punctuation">(</span><span class="token string">&quot;192.168.0.1:9876;192.168.0.2:9876&quot;</span><span class="token punctuation">)</span><span class="token punctuation">;</span>
</code></pre> <div class="line-numbers-wrapper"><span class="line-number">1</span><br><span class="line-number">2</span><br></div></div><ul><li>Java启动参数中指定Name Server地址</li></ul> <div class="language-bash line-numbers-mode"><pre class="language-bash"><code>-Drocketmq.namesrv.addr<span class="token operator">=</span><span class="token number">192.168</span>.0.1:9876<span class="token punctuation">;</span><span class="token number">192.168</span>.0.2:9876  
</code></pre> <div class="line-numbers-wrapper"><span class="line-number">1</span><br></div></div><ul><li>环境变量指定Name Server地址</li></ul> <div class="language-bash line-numbers-mode"><pre class="language-bash"><code><span class="token builtin class-name">export</span>   <span class="token assign-left variable">NAMESRV_ADDR</span><span class="token operator">=</span><span class="token number">192.168</span>.0.1:9876<span class="token punctuation">;</span><span class="token number">192.168</span>.0.2:9876   
</code></pre> <div class="line-numbers-wrapper"><span class="line-number">1</span><br></div></div><ul><li>HTTP静态服务器寻址（默认）</li></ul> <p>客户端启动后，会定时访问一个静态HTTP服务器，地址如下：<a href="http://jmenv.tbsite.net:8080/rocketmq/nsaddr" target="_blank" rel="noopener noreferrer">http://jmenv.tbsite.net:8080/rocketmq/nsaddr<span><svg xmlns="http://www.w3.org/2000/svg" aria-hidden="true" focusable="false" x="0px" y="0px" viewBox="0 0 100 100" width="15" height="15" class="icon outbound"><path fill="currentColor" d="M18.8,85.1h56l0,0c2.2,0,4-1.8,4-4v-32h-8v28h-48v-48h28v-8h-32l0,0c-2.2,0-4,1.8-4,4v56C14.8,83.3,16.6,85.1,18.8,85.1z"></path> <polygon fill="currentColor" points="45.7,48.7 51.3,54.3 77.2,28.5 77.2,37.2 85.2,37.2 85.2,14.9 62.8,14.9 62.8,22.9 71.5,22.9"></polygon></svg> <span class="sr-only">(opens new window)</span></span></a>，这个URL的返回内容如下：</p> <div class="language-bash line-numbers-mode"><pre class="language-bash"><code><span class="token number">192.168</span>.0.1:9876<span class="token punctuation">;</span><span class="token number">192.168</span>.0.2:9876   
</code></pre> <div class="line-numbers-wrapper"><span class="line-number">1</span><br></div></div><p>客户端默认每隔2分钟访问一次这个HTTP服务器，并更新本地的Name Server地址。URL已经在代码中硬编码，可通过修改/etc/hosts文件来改变要访问的服务器，例如在/etc/hosts增加如下配置：</p> <div class="language-bash line-numbers-mode"><pre class="language-bash"><code><span class="token number">10.232</span>.22.67    jmenv.tbsite.net   
</code></pre> <div class="line-numbers-wrapper"><span class="line-number">1</span><br></div></div><p>推荐使用HTTP静态服务器寻址方式，好处是客户端部署简单，且Name Server集群可以热升级。</p> <h4 id="客户端配置-2"><a href="#客户端配置-2" class="header-anchor">#</a> 客户端配置</h4> <p>DefaultMQProducer、TransactionMQProducer、DefaultMQPushConsumer、DefaultMQPullConsumer都继承于ClientConfig类，ClientConfig为客户端的公共配置类。客户端的配置都是get、set形式，每个参数都可以用spring来配置，也可以在代码中配置，例如namesrvAddr这个参数可以这样配置，producer.setNamesrvAddr(&quot;192.168.0.1:9876&quot;)，其他参数同理。</p> <p><strong>客户端的公共配置</strong></p> <table><thead><tr><th>参数名</th> <th>默认值</th> <th>说明</th></tr></thead> <tbody><tr><td>namesrvAddr</td> <td></td> <td>Name Server地址列表，多个NameServer地址用分号隔开</td></tr> <tr><td>clientIP</td> <td>本机IP</td> <td>客户端本机IP地址，某些机器会发生无法识别客户端IP地址情况，需要应用在代码中强制指定</td></tr> <tr><td>instanceName</td> <td>DEFAULT</td> <td>客户端实例名称，客户端创建的多个Producer、Consumer实际是共用一个内部实例（这个实例包含网络连接、线程资源等）</td></tr> <tr><td>clientCallbackExecutorThreads</td> <td>4</td> <td>通信层异步回调线程数</td></tr> <tr><td>pollNameServerInteval</td> <td>30000</td> <td>轮询Name Server间隔时间，单位毫秒</td></tr> <tr><td>heartbeatBrokerInterval</td> <td>30000</td> <td>向Broker发送心跳间隔时间，单位毫秒</td></tr> <tr><td>persistConsumerOffsetInterval</td> <td>5000</td> <td>持久化Consumer消费进度间隔时间，单位毫秒</td></tr></tbody></table> <p><strong>Producer配置</strong></p> <table><thead><tr><th>参数名</th> <th>默认值</th> <th>说明</th></tr></thead> <tbody><tr><td>producerGroup</td> <td>DEFAULT_PRODUCER</td> <td>Producer组名，多个Producer如果属于一个应用，发送同样的消息，则应该将它们归为同一组</td></tr> <tr><td>createTopicKey</td> <td>TBW102</td> <td>在发送消息时，自动创建服务器不存在的topic，需要指定Key，该Key可用于配置发送消息所在topic的默认路由。</td></tr> <tr><td>defaultTopicQueueNums</td> <td>4</td> <td>在发送消息，自动创建服务器不存在的topic时，默认创建的队列数</td></tr> <tr><td>sendMsgTimeout</td> <td>3000</td> <td>发送消息超时时间，单位毫秒</td></tr> <tr><td>compressMsgBodyOverHowmuch</td> <td>4096</td> <td>消息Body超过多大开始压缩（Consumer收到消息会自动解压缩），单位字节</td></tr> <tr><td>retryAnotherBrokerWhenNotStoreOK</td> <td>FALSE</td> <td>如果发送消息返回sendResult，但是sendStatus!=SEND_OK，是否重试发送</td></tr> <tr><td>retryTimesWhenSendFailed</td> <td>2</td> <td>如果消息发送失败，最大重试次数，该参数只对同步发送模式起作用</td></tr> <tr><td>maxMessageSize</td> <td>4MB</td> <td>客户端限制的消息大小，超过报错，同时服务端也会限制，所以需要跟服务端配合使用。</td></tr> <tr><td>transactionCheckListener</td> <td></td> <td>事务消息回查监听器，如果发送事务消息，必须设置</td></tr> <tr><td>checkThreadPoolMinSize</td> <td>1</td> <td>Broker回查Producer事务状态时，线程池最小线程数</td></tr> <tr><td>checkThreadPoolMaxSize</td> <td>1</td> <td>Broker回查Producer事务状态时，线程池最大线程数</td></tr> <tr><td>checkRequestHoldMax</td> <td>2000</td> <td>Broker回查Producer事务状态时，Producer本地缓冲请求队列大小</td></tr> <tr><td>RPCHook</td> <td>null</td> <td>该参数是在Producer创建时传入的，包含消息发送前的预处理和消息响应后的处理两个接口，用户可以在第一个接口中做一些安全控制或者其他操作。</td></tr></tbody></table> <p><strong>PushConsumer配置</strong></p> <table><thead><tr><th>参数名</th> <th>默认值</th> <th>说明</th></tr></thead> <tbody><tr><td>consumerGroup</td> <td>DEFAULT_CONSUMER</td> <td>Consumer组名，多个Consumer如果属于一个应用，订阅同样的消息，且消费逻辑一致，则应该将它们归为同一组</td></tr> <tr><td>messageModel</td> <td>CLUSTERING</td> <td>消费模型支持集群消费和广播消费两种</td></tr> <tr><td>consumeFromWhere</td> <td>CONSUME_FROM_LAST_OFFSET</td> <td>Consumer启动后，默认从上次消费的位置开始消费，这包含两种情况：一种是上次消费的位置未过期，则消费从上次中止的位置进行；一种是上次消费位置已经过期，则从当前队列第一条消息开始消费</td></tr> <tr><td>consumeTimestamp</td> <td>半个小时前</td> <td>只有当consumeFromWhere值为CONSUME_FROM_TIMESTAMP时才起作用。</td></tr> <tr><td>allocateMessageQueueStrategy</td> <td>AllocateMessageQueueAveragely</td> <td>Rebalance算法实现策略</td></tr> <tr><td>subscription</td> <td></td> <td>订阅关系</td></tr> <tr><td>messageListener</td> <td></td> <td>消息监听器</td></tr> <tr><td>offsetStore</td> <td></td> <td>消费进度存储</td></tr> <tr><td>consumeThreadMin</td> <td>20</td> <td>消费线程池最小线程数</td></tr> <tr><td>consumeThreadMax</td> <td>20</td> <td>消费线程池最大线程数</td></tr> <tr><td>consumeConcurrentlyMaxSpan</td> <td>2000</td> <td>单队列并行消费允许的最大跨度</td></tr> <tr><td>pullThresholdForQueue</td> <td>1000</td> <td>拉消息本地队列缓存消息最大数</td></tr> <tr><td>pullInterval</td> <td>0</td> <td>拉消息间隔，由于是长轮询，所以为0，但是如果应用为了流控，也可以设置大于0的值，单位毫秒</td></tr> <tr><td>consumeMessageBatchMaxSize</td> <td>1</td> <td>批量消费，一次消费多少条消息</td></tr> <tr><td>pullBatchSize</td> <td>32</td> <td>批量拉消息，一次最多拉多少条</td></tr></tbody></table> <p><strong>PullConsumer配置</strong></p> <table><thead><tr><th>参数名</th> <th>默认值</th> <th>说明</th></tr></thead> <tbody><tr><td>consumerGroup</td> <td>DEFAULT_CONSUMER</td> <td>Consumer组名，多个Consumer如果属于一个应用，订阅同样的消息，且消费逻辑一致，则应该将它们归为同一组</td></tr> <tr><td>brokerSuspendMaxTimeMillis</td> <td>20000</td> <td>长轮询，Consumer拉消息请求在Broker挂起最长时间，单位毫秒</td></tr> <tr><td>consumerTimeoutMillisWhenSuspend</td> <td>30000</td> <td>长轮询，Consumer拉消息请求在Broker挂起超过指定时间，客户端认为超时，单位毫秒</td></tr> <tr><td>consumerPullTimeoutMillis</td> <td>10000</td> <td>非长轮询，拉消息超时时间，单位毫秒</td></tr> <tr><td>messageModel</td> <td>BROADCASTING</td> <td>消息支持两种模式：集群消费和广播消费</td></tr> <tr><td>messageQueueListener</td> <td></td> <td>监听队列变化</td></tr> <tr><td>offsetStore</td> <td></td> <td>消费进度存储</td></tr> <tr><td>registerTopics</td> <td></td> <td>注册的topic集合</td></tr> <tr><td>allocateMessageQueueStrategy</td> <td>AllocateMessageQueueAveragely</td> <td>Rebalance算法实现策略</td></tr></tbody></table> <p><strong>Message数据结构</strong></p> <table><thead><tr><th>字段名</th> <th>默认值</th> <th>说明</th></tr></thead> <tbody><tr><td>Topic</td> <td>null</td> <td>必填，消息所属topic的名称</td></tr> <tr><td>Body</td> <td>null</td> <td>必填，消息体</td></tr> <tr><td>Tags</td> <td>null</td> <td>选填，消息标签，方便服务器过滤使用。目前只支持每个消息设置一个tag</td></tr> <tr><td>Keys</td> <td>null</td> <td>选填，代表这条消息的业务关键词，服务器会根据keys创建哈希索引，设置后，可以在Console系统根据Topic、Keys来查询消息，由于是哈希索引，请尽可能保证key唯一，例如订单号，商品Id等。</td></tr> <tr><td>Flag</td> <td>0</td> <td>选填，完全由应用来设置，RocketMQ不做干预</td></tr> <tr><td>DelayTimeLevel</td> <td>0</td> <td>选填，消息延时级别，0表示不延时，大于0会延时特定的时间才会被消费</td></tr> <tr><td>WaitStoreMsgOK</td> <td>TRUE</td> <td>选填，表示消息是否在服务器落盘后才返回应答。</td></tr></tbody></table> <h3 id="系统配置"><a href="#系统配置" class="header-anchor">#</a> 系统配置</h3> <p>本小节主要介绍系统（JVM/OS）相关的配置。</p> <h4 id="jvm选项"><a href="#jvm选项" class="header-anchor">#</a> JVM选项</h4> <p>推荐使用最新发布的JDK 1.8版本。通过设置相同的Xms和Xmx值来防止JVM调整堆大小以获得更好的性能。简单的JVM配置如下所示：</p> <div class="language-bash line-numbers-mode"><pre class="language-bash"><code>-server -Xms8g -Xmx8g -Xmn4g   
</code></pre> <div class="line-numbers-wrapper"><span class="line-number">1</span><br></div></div><p>如果您不关心RocketMQ Broker的启动时间，还有一种更好的选择，就是通过“预触摸”Java堆以确保在JVM初始化期间每个页面都将被分配。那些不关心启动时间的人可以启用它：</p> <p>-XX:+AlwaysPreTouch</p> <p>禁用偏置锁定可能会减少JVM暂停。</p> <p>-XX:-UseBiasedLocking</p> <p>至于垃圾回收，建议使用带JDK 1.8的G1收集器。</p> <div class="language-bash line-numbers-mode"><pre class="language-bash"><code>-XX:+UseG1GC -XX:G1HeapRegionSize<span class="token operator">=</span>16m   
-XX:G1ReservePercent<span class="token operator">=</span><span class="token number">25</span> 
-XX:InitiatingHeapOccupancyPercent<span class="token operator">=</span><span class="token number">30</span>
</code></pre> <div class="line-numbers-wrapper"><span class="line-number">1</span><br><span class="line-number">2</span><br><span class="line-number">3</span><br></div></div><p>这些GC选项看起来有点激进，但事实证明它在我们的生产环境中具有良好的性能。另外不要把-XX:MaxGCPauseMillis的值设置太小，否则JVM将使用一个小的年轻代来实现这个目标，这将导致非常频繁的minor GC，所以建议使用rolling GC日志文件：</p> <div class="language-bash line-numbers-mode"><pre class="language-bash"><code>-XX:+UseGCLogFileRotation   
-XX:NumberOfGCLogFiles<span class="token operator">=</span><span class="token number">5</span> 
-XX:GCLogFileSize<span class="token operator">=</span>30m
</code></pre> <div class="line-numbers-wrapper"><span class="line-number">1</span><br><span class="line-number">2</span><br><span class="line-number">3</span><br></div></div><p>如果写入GC文件会增加代理的延迟，可以考虑将GC日志文件重定向到内存文件系统：</p> <div class="language-bash line-numbers-mode"><pre class="language-bash"><code>-Xloggc:/dev/shm/mq_gc_%p.log123   
</code></pre> <div class="line-numbers-wrapper"><span class="line-number">1</span><br></div></div><h4 id="linux内核参数"><a href="#linux内核参数" class="header-anchor">#</a> Linux内核参数</h4> <p>os.sh脚本在bin文件夹中列出了许多内核参数，可以进行微小的更改然后用于生产用途。下面的参数需要注意，更多细节请参考/proc/sys/vm/*的<a href="https://www.kernel.org/doc/Documentation/sysctl/vm.txt" target="_blank" rel="noopener noreferrer">文档<span><svg xmlns="http://www.w3.org/2000/svg" aria-hidden="true" focusable="false" x="0px" y="0px" viewBox="0 0 100 100" width="15" height="15" class="icon outbound"><path fill="currentColor" d="M18.8,85.1h56l0,0c2.2,0,4-1.8,4-4v-32h-8v28h-48v-48h28v-8h-32l0,0c-2.2,0-4,1.8-4,4v56C14.8,83.3,16.6,85.1,18.8,85.1z"></path> <polygon fill="currentColor" points="45.7,48.7 51.3,54.3 77.2,28.5 77.2,37.2 85.2,37.2 85.2,14.9 62.8,14.9 62.8,22.9 71.5,22.9"></polygon></svg> <span class="sr-only">(opens new window)</span></span></a></p> <ul><li><strong>vm.extra_free_kbytes</strong>，告诉VM在后台回收（kswapd）启动的阈值与直接回收（通过分配进程）的阈值之间保留额外的可用内存。RocketMQ使用此参数来避免内存分配中的长延迟。（与具体内核版本相关）</li> <li><strong>vm.min_free_kbytes</strong>，如果将其设置为低于1024KB，将会巧妙的将系统破坏，并且系统在高负载下容易出现死锁。</li> <li><strong>vm.max_map_count</strong>，限制一个进程可能具有的最大内存映射区域数。RocketMQ将使用mmap加载CommitLog和ConsumeQueue，因此建议将为此参数设置较大的值。（agressiveness --&gt; aggressiveness）</li> <li><strong>vm.swappiness</strong>，定义内核交换内存页面的积极程度。较高的值会增加攻击性，较低的值会减少交换量。建议将值设置为10来避免交换延迟。</li> <li><strong>File descriptor limits</strong>，RocketMQ需要为文件（CommitLog和ConsumeQueue）和网络连接打开文件描述符。我们建议设置文件描述符的值为655350。</li> <li><a href="https://access.redhat.com/documentation/en-US/Red_Hat_Enterprise_Linux/6/html/Performance_Tuning_Guide/ch06s04s02.html" target="_blank" rel="noopener noreferrer">Disk scheduler<span><svg xmlns="http://www.w3.org/2000/svg" aria-hidden="true" focusable="false" x="0px" y="0px" viewBox="0 0 100 100" width="15" height="15" class="icon outbound"><path fill="currentColor" d="M18.8,85.1h56l0,0c2.2,0,4-1.8,4-4v-32h-8v28h-48v-48h28v-8h-32l0,0c-2.2,0-4,1.8-4,4v56C14.8,83.3,16.6,85.1,18.8,85.1z"></path> <polygon fill="currentColor" points="45.7,48.7 51.3,54.3 77.2,28.5 77.2,37.2 85.2,37.2 85.2,14.9 62.8,14.9 62.8,22.9 71.5,22.9"></polygon></svg> <span class="sr-only">(opens new window)</span></span></a>，RocketMQ建议使用I/O截止时间调度器，它试图为请求提供有保证的延迟。</li></ul> <p align="right"><font size="1">注意：本章内容大部分内容来源：https://github.com/apache/rocketmq/tree/master/docs/cn</font></p> <p><strong>好了，今天我们就到儿吧，限于篇幅，文中并未给出完整的案例源代码，想要完整源代码的小伙伴可加入【冰河技术】知识星球获取源码。也可以加我微信：hacker_binghe，一起交流技术。</strong></p> <p><strong>另外，一不小心就写了20章了，小伙伴们你们再不上车就真的跟不上了！！！</strong></p> <h2 id="关于星球"><a href="#关于星球" class="header-anchor">#</a> 关于星球</h2> <p>最近，冰河创建了【冰河技术】知识星球，《<a href="https://mp.weixin.qq.com/mp/appmsgalbum?__biz=Mzg4MjU0OTM1OA==&amp;action=getalbum&amp;album_id=2337104419664084992&amp;scene=173&amp;from_msgid=2247500214&amp;from_itemidx=1&amp;count=3&amp;nolastread=1#wechat_redirect" target="_blank" rel="noopener noreferrer">SpringCloud Alibaba实战<span><svg xmlns="http://www.w3.org/2000/svg" aria-hidden="true" focusable="false" x="0px" y="0px" viewBox="0 0 100 100" width="15" height="15" class="icon outbound"><path fill="currentColor" d="M18.8,85.1h56l0,0c2.2,0,4-1.8,4-4v-32h-8v28h-48v-48h28v-8h-32l0,0c-2.2,0-4,1.8-4,4v56C14.8,83.3,16.6,85.1,18.8,85.1z"></path> <polygon fill="currentColor" points="45.7,48.7 51.3,54.3 77.2,28.5 77.2,37.2 85.2,37.2 85.2,14.9 62.8,14.9 62.8,22.9 71.5,22.9"></polygon></svg> <span class="sr-only">(opens new window)</span></span></a>》专栏的源码获取方式会放到知识星球中，同时在微信上会创建专门的知识星球群，冰河会在知识星球上和星球群里解答球友的提问。</p> <p>今天，【冰河技术】知识星球再开放200张优惠券，还没上车的小伙伴赶紧啦，再不上车就跟不上啦！！</p> <h3 id="星球提供的服务"><a href="#星球提供的服务" class="header-anchor">#</a> 星球提供的服务</h3> <p>冰河整理了星球提供的一些服务，如下所示。</p> <p>加入星球，你将获得：</p> <p>1.学习SpringCloud Alibaba实战项目—从零开发微服务项目</p> <p>2.学习高并发、大流量业务场景的解决方案，体验大厂真正的高并发、大流量的业务场景</p> <p>3.学习进大厂必备技能：性能调优、并发编程、分布式、微服务、框架源码、中间件开发、项目实战</p> <p>4.提供站点 https://binghe001.github.io 所有学习内容的指导、帮助</p> <p>5.GitHub：https://github.com/binghe001/BingheGuide - 非常有价值的技术资料仓库，包括冰河所有的博客开放案例代码</p> <p>6.可以发送你的简历到我的邮箱，提供简历批阅服务</p> <p>7.提供技术问题、系统架构、学习成长、晋升答辩等各项内容的回答</p> <p>8.定期的整理和分享出各类专属星球的技术小册、电子书、编程视频、PDF文件</p> <p>9.定期组织技术直播分享，传道、授业、解惑，指导阶段瓶颈突破技巧</p> <h3 id="星球门票价格"><a href="#星球门票价格" class="header-anchor">#</a> 星球门票价格</h3> <p>星球目前的门票价格50元，随着每次加入新实战项目和分享硬核技术上调入场价格。</p> <p><strong>特别提醒：</strong> 苹果用户进圈或续费，请加微信「hacker_binghe」扫二维码，或者去公众号「冰河技术」回复「星球」扫二维码进圈。</p> <p>最后，小伙伴们可以扫描或者长按下图中的二维码加入星球，也可以在 <strong>冰河技术</strong> 公众号回复 “ <strong>星球</strong> ” ，领取入场优惠券。</p> <p><img alt="sa-2022-04-21-007" data-src="https://binghe001.github.io/assets/images/microservices/springcloudalibaba/sa-2022-04-28-008.png" loading="lazy" class="lazy"></p> <p><strong>好了，今天就到这儿吧，我是冰河，我们下期见~~</strong></p> <h2 id="写在最后"><a href="#写在最后" class="header-anchor">#</a> 写在最后</h2> <blockquote><p>如果你觉得冰河写的还不错，请微信搜索并关注「 <strong>冰河技术</strong> 」微信公众号，跟冰河学习高并发、分布式、微服务、大数据、互联网和云原生技术，「 <strong>冰河技术</strong> 」微信公众号更新了大量技术专题，每一篇技术文章干货满满！不少读者已经通过阅读「 <strong>冰河技术</strong> 」微信公众号文章，吊打面试官，成功跳槽到大厂；也有不少读者实现了技术上的飞跃，成为公司的技术骨干！如果你也想像他们一样提升自己的能力，实现技术能力的飞跃，进大厂，升职加薪，那就关注「 <strong>冰河技术</strong> 」微信公众号吧，每天更新超硬核技术干货，让你对如何提升技术能力不再迷茫！</p></blockquote> <p><img alt="" data-src="https://img-blog.csdnimg.cn/20200906013715889.png" loading="lazy" class="lazy"></p></div> <footer class="page-edit"><div class="edit-link"><a href="https://github.com/binghe001/BingheGuide/edit/master/docs/md/microservices/springcloudalibaba/2022-05-20-SA实战-第20章-消息服务-RocketMQ核心技术.md" target="_blank" rel="noopener noreferrer">在 GitHub 上编辑此页</a> <span><svg xmlns="http://www.w3.org/2000/svg" aria-hidden="true" focusable="false" x="0px" y="0px" viewBox="0 0 100 100" width="15" height="15" class="icon outbound"><path fill="currentColor" d="M18.8,85.1h56l0,0c2.2,0,4-1.8,4-4v-32h-8v28h-48v-48h28v-8h-32l0,0c-2.2,0-4,1.8-4,4v56C14.8,83.3,16.6,85.1,18.8,85.1z"></path> <polygon fill="currentColor" points="45.7,48.7 51.3,54.3 77.2,28.5 77.2,37.2 85.2,37.2 85.2,14.9 62.8,14.9 62.8,22.9 71.5,22.9"></polygon></svg> <span class="sr-only">(opens new window)</span></span></div> <div class="last-updated"><span class="prefix">上次更新: </span> <span class="time">2022/5/23</span></div></footer> <div class="page-nav"><p class="inner"><span class="prev">
        ←
        <a href="/md/microservices/springcloudalibaba/2022-05-18-SA实战-第19章-消息服务-项目整合RocketMQ.html" class="prev">
          SA实战 ·《SpringCloud Alibaba实战》第19章-消息服务：项目整合RocketMQ
        </a></span> <span class="next"><a href="/md/microservices/springcloudalibaba/2022-05-21-SA实战-第21章-服务配置-服务配置介绍与Nacos核心概念.html">
          SA实战 ·《SpringCloud Alibaba实战》第21章-服务配置：服务配置介绍与Nacos核心概念
        </a>
        →
      </span></p></div> </main></div> <aside class="page-sidebar"> <div class="page-side-toolbar"><div class="option-box-toc-fixed"><div class="toc-container-sidebar"><div class="pos-box"><div class="icon-arrow"></div> <div class="scroll-box" style="max-height:650px"><div style="font-weight:bold;text-align:center;">SA实战 ·《SpringCloud Alibaba实战》第20章-消息服务：RocketMQ核心技术</div> <hr> <div class="toc-box"><ul class="toc-sidebar-links"><li><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#本章总览" class="toc-sidebar-link">本章总览</a><ul class="toc-sidebar-sub-headers"></ul></li><li><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#idea启动rocketmq源码" class="toc-sidebar-link">IDEA启动RocketMQ源码</a><ul class="toc-sidebar-sub-headers"><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#下载rocketmq源码" class="toc-sidebar-link">下载RocketMQ源码</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#将源码导入idea" class="toc-sidebar-link">将源码导入IDEA</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#编译rocketmq源码" class="toc-sidebar-link">编译RocketMQ源码</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#启动rocketmq" class="toc-sidebar-link">启动RocketMQ</a></li></ul></li><li><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#rocketmq基本概念" class="toc-sidebar-link">RocketMQ基本概念</a><ul class="toc-sidebar-sub-headers"><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息模型" class="toc-sidebar-link">消息模型</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息生产者" class="toc-sidebar-link">消息生产者</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息消费者" class="toc-sidebar-link">消息消费者</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#主题" class="toc-sidebar-link">主题</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#代理服务器" class="toc-sidebar-link">代理服务器</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#名字服务" class="toc-sidebar-link">名字服务</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#拉取式消费" class="toc-sidebar-link">拉取式消费</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#推动式消费" class="toc-sidebar-link">推动式消费</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#生产者组" class="toc-sidebar-link">生产者组</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消费者组" class="toc-sidebar-link">消费者组</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#集群消费" class="toc-sidebar-link">集群消费</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#广播消费" class="toc-sidebar-link">广播消费</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#普通顺序消息" class="toc-sidebar-link">普通顺序消息</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#严格顺序消息" class="toc-sidebar-link">严格顺序消息</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息" class="toc-sidebar-link">消息</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#标签" class="toc-sidebar-link">标签</a></li></ul></li><li><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#rocketmq特性" class="toc-sidebar-link">RocketMQ特性</a><ul class="toc-sidebar-sub-headers"><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#订阅与发布" class="toc-sidebar-link">订阅与发布</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息顺序" class="toc-sidebar-link">消息顺序</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息过滤" class="toc-sidebar-link">消息过滤</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息可靠性" class="toc-sidebar-link">消息可靠性</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#至少一次" class="toc-sidebar-link">至少一次</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#回溯消费" class="toc-sidebar-link">回溯消费</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#事务消息" class="toc-sidebar-link">事务消息</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#定时消息" class="toc-sidebar-link">定时消息</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息重试" class="toc-sidebar-link">消息重试</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息重投" class="toc-sidebar-link">消息重投</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#流量控制" class="toc-sidebar-link">流量控制</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#死信队列" class="toc-sidebar-link">死信队列</a></li></ul></li><li><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#rocketmq最佳实践" class="toc-sidebar-link">RocketMQ最佳实践</a><ul class="toc-sidebar-sub-headers"><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#生产者" class="toc-sidebar-link">生产者</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消费者" class="toc-sidebar-link">消费者</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#broker" class="toc-sidebar-link">Broker</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#nameserver" class="toc-sidebar-link">NameServer</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#客户端配置" class="toc-sidebar-link">客户端配置</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#系统配置" class="toc-sidebar-link">系统配置</a></li></ul></li><li><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#关于星球" class="toc-sidebar-link">关于星球</a><ul class="toc-sidebar-sub-headers"><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#星球提供的服务" class="toc-sidebar-link">星球提供的服务</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#星球门票价格" class="toc-sidebar-link">星球门票价格</a></li></ul></li><li><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#写在最后" class="toc-sidebar-link">写在最后</a><ul class="toc-sidebar-sub-headers"></ul></li></ul></div></div></div></div></div> <div class="option-box-toc-over"><img src="/images/system/toc.png" class="nozoom"> <span class="show-txt">目录</span> <div class="toc-container"><div class="pos-box"><div class="icon-arrow"></div> <div class="scroll-box" style="max-height:550px"><div style="font-weight:bold;text-align:center;">SA实战 ·《SpringCloud Alibaba实战》第20章-消息服务：RocketMQ核心技术</div> <hr> <div class="toc-box"><ul class="toc-sidebar-links"><li><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#本章总览" class="toc-sidebar-link">本章总览</a><ul class="toc-sidebar-sub-headers"></ul></li><li><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#idea启动rocketmq源码" class="toc-sidebar-link">IDEA启动RocketMQ源码</a><ul class="toc-sidebar-sub-headers"><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#下载rocketmq源码" class="toc-sidebar-link">下载RocketMQ源码</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#将源码导入idea" class="toc-sidebar-link">将源码导入IDEA</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#编译rocketmq源码" class="toc-sidebar-link">编译RocketMQ源码</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#启动rocketmq" class="toc-sidebar-link">启动RocketMQ</a></li></ul></li><li><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#rocketmq基本概念" class="toc-sidebar-link">RocketMQ基本概念</a><ul class="toc-sidebar-sub-headers"><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息模型" class="toc-sidebar-link">消息模型</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息生产者" class="toc-sidebar-link">消息生产者</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息消费者" class="toc-sidebar-link">消息消费者</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#主题" class="toc-sidebar-link">主题</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#代理服务器" class="toc-sidebar-link">代理服务器</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#名字服务" class="toc-sidebar-link">名字服务</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#拉取式消费" class="toc-sidebar-link">拉取式消费</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#推动式消费" class="toc-sidebar-link">推动式消费</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#生产者组" class="toc-sidebar-link">生产者组</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消费者组" class="toc-sidebar-link">消费者组</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#集群消费" class="toc-sidebar-link">集群消费</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#广播消费" class="toc-sidebar-link">广播消费</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#普通顺序消息" class="toc-sidebar-link">普通顺序消息</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#严格顺序消息" class="toc-sidebar-link">严格顺序消息</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息" class="toc-sidebar-link">消息</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#标签" class="toc-sidebar-link">标签</a></li></ul></li><li><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#rocketmq特性" class="toc-sidebar-link">RocketMQ特性</a><ul class="toc-sidebar-sub-headers"><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#订阅与发布" class="toc-sidebar-link">订阅与发布</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息顺序" class="toc-sidebar-link">消息顺序</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息过滤" class="toc-sidebar-link">消息过滤</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息可靠性" class="toc-sidebar-link">消息可靠性</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#至少一次" class="toc-sidebar-link">至少一次</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#回溯消费" class="toc-sidebar-link">回溯消费</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#事务消息" class="toc-sidebar-link">事务消息</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#定时消息" class="toc-sidebar-link">定时消息</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息重试" class="toc-sidebar-link">消息重试</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消息重投" class="toc-sidebar-link">消息重投</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#流量控制" class="toc-sidebar-link">流量控制</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#死信队列" class="toc-sidebar-link">死信队列</a></li></ul></li><li><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#rocketmq最佳实践" class="toc-sidebar-link">RocketMQ最佳实践</a><ul class="toc-sidebar-sub-headers"><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#生产者" class="toc-sidebar-link">生产者</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#消费者" class="toc-sidebar-link">消费者</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#broker" class="toc-sidebar-link">Broker</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#nameserver" class="toc-sidebar-link">NameServer</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#客户端配置" class="toc-sidebar-link">客户端配置</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#系统配置" class="toc-sidebar-link">系统配置</a></li></ul></li><li><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#关于星球" class="toc-sidebar-link">关于星球</a><ul class="toc-sidebar-sub-headers"><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#星球提供的服务" class="toc-sidebar-link">星球提供的服务</a></li><li class="toc-sidebar-sub-header"><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#星球门票价格" class="toc-sidebar-link">星球门票价格</a></li></ul></li><li><a href="/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html#写在最后" class="toc-sidebar-link">写在最后</a><ul class="toc-sidebar-sub-headers"></ul></li></ul></div></div></div></div></div> <div class="option-box"><img src="/images/system/wechat.png" class="nozoom"> <span class="show-txt">手机看</span> <div class="toc-container"><div class="pos-box"><div class="icon-arrow"></div> <div class="scroll-box" style="text-align:center"><span style="font-size:0.9rem">微信扫一扫</span> <img height="180px" src="https://api.qrserver.com/v1/create-qr-code/?data=https://binghe001.github.io/md/microservices/springcloudalibaba/2022-05-20-SA%E5%AE%9E%E6%88%98-%E7%AC%AC20%E7%AB%A0-%E6%B6%88%E6%81%AF%E6%9C%8D%E5%8A%A1-RocketMQ%E6%A0%B8%E5%BF%83%E6%8A%80%E6%9C%AF.html" style="margin:10px;">
                可以<b>手机看</b>或分享至<b>朋友圈</b></div></div></div></div> <div class="option-box"><img src="/images/system/toggle.png" width="30px" class="nozoom"> <span class="show-txt">左栏</span></div> <div class="option-box"><img src="/images/system/xingqiu.png" width="25px" class="nozoom"> <span class="show-txt">星球</span> <div class="toc-container"><div class="pos-box"><div class="icon-arrow"></div> <div class="scroll-box" style="text-align:center"><span style="font-size:0.8rem;font-weight:bold;">实战项目<span style="font-size:8px;color:red;">「SpringCloud Alibaba实战项目」</span>、专属电子书、问题解答、简历指导、技术分享、晋升指导、视频课程</span> <img height="180px" src="/images/personal/xingqiu.png" style="margin:10px;"> <b>知识星球</b>：冰河技术
            </div></div></div></div> <div class="option-box"><img src="/images/system/wexin4.png" width="25px" class="nozoom"> <span class="show-txt">读者群</span> <div class="toc-container"><div class="pos-box"><div class="icon-arrow"></div> <div class="scroll-box" style="text-align:center"><span style="font-size:0.8rem;font-weight:bold;">添加冰河微信<span style="color:red;">(hacker_binghe)</span>进冰河技术学习交流圈「无任何套路」</span> <img src="/images/personal/hacker_binghe.jpg" height="180px" style="margin:10px;">
                PS：添加时请备注<b>读者加群</b>，谢谢！
              </div></div></div></div> <div class="option-box"><img src="/images/system/download-2.png" width="25px" class="nozoom"> <span class="show-txt">下资料</span> <div class="toc-container"><div class="pos-box"><div class="icon-arrow"></div> <div class="scroll-box" style="text-align:center"><span style="font-size:0.8rem;font-weight:bold;">扫描公众号，回复<span style="color:red;">“1024”</span>下载<span style="color:red;">100GB+</span>学习技术资料、PDF书籍、实战项目、简历模板等「无任何套路」</span> <img src="/images/personal/qrcode.png" height="180px" style="margin:10px;"> <b>公众号:</b> 冰河技术
              </div></div></div></div> <div class="option-box"><img src="/images/system/heart-1.png" width="25px" class="nozoom"> <span class="show-txt">赞赏我</span> <div class="toc-container"><div class="pos-box"><div class="icon-arrow"></div> <div class="scroll-box" style="text-align:center"><span style="font-size:0.8rem;font-weight:bold;">鼓励/支持/赞赏我</span> <img height="180px" src="/images/personal/encourage-head.png" style="margin:5px;"> <br>1. 不靠它生存但仍希望得到你的鼓励；
                <br>2. 时刻警醒自己保持技术人的初心；
              </div></div></div></div> <div title="SA实战 ·《SpringCloud Alibaba实战》第19章-消息服务：项目整合RocketMQ" class="option-box" style="padding-left:2px;text-align:center;"><a href="/md/microservices/springcloudalibaba/2022-05-18-SA实战-第19章-消息服务-项目整合RocketMQ.html"><img src="/images/system/pre2.png" width="30px" class="nozoom"> <span class="show-txt">上一篇</span></a></div> <div title="SA实战 ·《SpringCloud Alibaba实战》第21章-服务配置：服务配置介绍与Nacos核心概念" class="option-box" style="padding-left:2px;text-align:center;"><a href="/md/microservices/springcloudalibaba/2022-05-21-SA实战-第21章-服务配置-服务配置介绍与Nacos核心概念.html"><img src="/images/system/next2.png" width="30px" class="nozoom"> <span class="show-txt">下一篇</span></a></div></div>  <!----> </aside></div><div class="global-ui"><div class="read-more-wrap" style="display:none;position:absolute;bottom:0px;z-index:9999;width:100%;margin-top:-100px;font-family:PingFangSC-Regular, sans-serif;"><div id="read-more-mask" style="position: relative; height: 200px; background: -webkit-gradient(linear, 0 0%, 0 100%, from(rgba(255, 255, 255, 0)), to(rgb(255, 255, 255)));"></div> <a id="read-more-btn" target="_self" style="position: absolute; left: 50%; top: 70%; bottom: 30px; transform: translate(-50%, -50%); width: 160px; height: 36px; line-height: 36px; font-size: 15px; text-align: center; border: 1px solid rgb(222, 104, 109); color: rgb(222, 104, 109); background: rgb(255, 255, 255); cursor: pointer; border-radius: 6px;">阅读全文</a> <div id="btw-modal-wrap" style="display: none;"><div id="btw-mask" style="position: fixed; top: 0px; right: 0px; bottom: 0px; left: 0px; opacity: 0.7; z-index: 999; background: rgb(0, 0, 0);"></div> <div id="btw-modal" style="position: fixed; top: 50%; left: 50%; transform: translate(-50%, -50%); width: 300px; text-align: center; font-size: 13px; background: rgb(255, 255, 255); border-radius: 10px; z-index: 9999; font-family: PingFangSC-Regular, sans-serif;"><span id="btw-modal-close-btn" style="position: absolute; top: 5px; right: 15px; line-height: 34px; font-size: 34px; cursor: pointer; opacity: 0.2; z-index: 9999; color: rgb(0, 0, 0); background: none; border: none; outline: none;">×</span> <p id="btw-modal-header" style="margin-top: 40px; line-height: 1.8; font-size: 13px;">
                扫码或搜索：<span style="color: #E9405A; font-weight: bold;">冰河技术</span> <br>发送：<span id="fustack-token" class="token" style="color: #e9415a; font-weight: bold; font-size: 17px; margin-bottom: 45px;">290992</span> <br>即可<span style="color: #e9415a; font-weight: bold;">立即永久</span>解锁本站全部文章</p> <img src="/images/personal/qrcode.png" style="width: 180px; margin-top: 10px; margin-bottom: 30px; border: 8px solid rgb(230, 230, 230);"></div></div></div><div class="pay-read-more-wrap" style="display:none;position:absolute;bottom:0px;z-index:9999;width:100%;margin-top:-100px;font-family:PingFangSC-Regular, sans-serif;"><div id="pay-read-more-mask" style="position: relative; height: 200px; background: -webkit-gradient(linear, 0 0%, 0 100%, from(rgba(255, 255, 255, 0)), to(rgb(255, 255, 255)));"></div> <a id="pay-read-more-btn" target="_blank" style="position: absolute; left: 50%; top: 70%; bottom: 30px; transform: translate(-50%, -50%); width: 160px; height: 36px; line-height: 36px; font-size: 15px; text-align: center; border: 1px solid rgb(222, 104, 109); color: rgb(222, 104, 109); background: rgb(255, 255, 255); cursor: pointer; border-radius: 6px;">付费阅读</a></div></div></div>
    <script src="/assets/js/cg-styles.js?v=1653305936337" defer></script><script src="/assets/js/cg-4.js?v=1653305936337" defer></script><script src="/assets/js/cg-3.js?v=1653305936337" defer></script><script src="/assets/js/cg-308.js?v=1653305936337" defer></script><script src="/assets/js/cg-5.js?v=1653305936337" defer></script><script src="/assets/js/cg-6.js?v=1653305936337" defer></script><script src="/assets/js/cg-app.js?v=1653305936337" defer></script>
  </body>
</html>
